import tensorflow as tf q = tf.FIFOQueue(2, "int32") init = q.enqueue_many(([0, 10],)) x = q.dequeue() y = x + 1 q_inc = q.enqueue([y]) with tf.Session() as sess: init.run() for _ in range(5): v, _ = sess.run([x, q_inc]) print(v)
import time import threading import numpy as np def MyLoop(coord, worker_id): while not coord.should_stop(): if np.random.rand()<0.1: print("Stoping from id: %d\n" % worker_id,coord.request_stop()) else: print("Working on id: %d\n" % worker_id, time.sleep(1))
coord = tf.train.Coordinator() threads = [threading.Thread(target=MyLoop, args=(coord, i, )) for i in xrange(5)] for t in threads: t.start() coord.join(threads)
原文地址:https://www.cnblogs.com/tszr/p/10885370.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。