Как сбросить генератор для каждого потока, g1 и g2.Фактический случай таков, что next(g1())
и next(g2())
дают упорядоченные значения из каждого пустого массива, в точности по порядку выполнения:
Мой фрагмент кода выглядит так:
import tensorflow as tf
def g1():
with tf.Session() as session:
gen1 = tf.estimator.inputs.numpy_input_fn(
res_train_flow['x'], res_train_flow['y'], batch_size=1, shuffle=False, num_epochs=1)
while True:
features, target = gen1()
yield features
def g2():
with tf.Session() as session:
gen2 = tf.estimator.inputs.numpy_input_fn(
res_train_flow['x'], res_train_flow['y'], batch_size=1, shuffle=False, num_epochs=1)
while True:
features, target = gen2()
yield features