# -*- coding: utf-8 -*-
"""
Created on Thu Oct 25 09:49:34 2018
@author: Grey
"""
import tensorflow as tf
#模拟同步 先处理数据再取数据训练
#会话运行
#1.定义队列
Q=tf.FIFOQueue(3,tf.float32)
#放入数据,列表，否则认为是张量
enq_many=Q.enqueue_many([[0.1,0.2,0.3],])
#2.定义处理数据的逻辑、取数据过程，取数据+1 再入队
out_q=Q.dequeue()#op
data=out_q+1
en_q=Q.enqueue(data)
with tf.Session() as sess:
# 初始化队列
sess.run(enq_many)
# 处理数据
for i in range(100):
sess.run(en_q)
# 训练数据
for i in range(Q.size().eval()):
print(sess.run(Q.dequeue()))
pass
未加同步，输出结果：
