小编Asd*_*f11的帖子

张量流/ keras中的多线程

我想在一个python应用程序中使用model.fit()并行训练一些不同的模型.使用的模型没有必要的共同点,它们在不同的时间在一个应用程序中启动.

首先,我在一个单独的线程中启动一个model.fit(),然后是主线程.如果我现在想要启动第二个model.fit(),我收到以下错误消息:

Exception in thread Thread-1:
tensorflow.python.framework.errors_impl.InvalidArgumentError: Node 'hidden_1/BiasAdd': Unknown input node 'hidden_1/MatMul'
Run Code Online (Sandbox Code Playgroud)

它们都是通过相同的代码行从一个方法开始的:

start_learn(self:)
   tf_session = K.get_session()  # this creates a new session since one doesn't exist already.
   tf_graph = tf.get_default_graph()

   keras_learn_thread.Learn(learning_data, model, self.env_cont, tf_session, tf_graph)
   learning_results.start()
Run Code Online (Sandbox Code Playgroud)

所谓的类/方法如下所示:

def run(self):
    tf_session = self.tf_session  # take that from __init__()
    tf_graph = self.tf_graph  # take that from __init__()

    with tf_session.as_default():
        with tf_graph.as_default():
            self.learn(self.learning_data, self.model, self.env_cont)
            # now my learn method where model.fit() is located is being started
Run Code Online (Sandbox Code Playgroud)

我想我不得不为每个单独的线程分配一个新的tf_session和一个新的tf_graph.但我对此并不十分肯定.我会为每一个简短的想法感到高兴,因为我现在坐在这里太久了.

谢谢

python multithreading keras tensorflow

9
推荐指数
1
解决办法
3314
查看次数

标签 统计

keras ×1

multithreading ×1

python ×1

tensorflow ×1