import tensorflow as tfq = tf.FIFOQueue(2, "int32")init = q.enqueue_many(([0, 10],))x = q.dequeue()y = x + 1q_inc = q.enqueue([y])with tf.Session() as sess:    init.run()    for _ in range(5):        v, _ = sess.run([x, q_inc])        print(v)

import timeimport threadingimport numpy as npdef 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)