1.读取文件列表#文件保存目录path='./data/iamge'file_names=os.listdir(path)file_list=[os.path.join(path,file_name)forfile_nameinfile_names]2.创建文件读取取队列file_queue=tf.train.string_inpurt_producer(file_list)3.创建图片读取器读取图片reader=tf.WholeFileReader()key,value=reader.read(file_queue)4.解析图片image=tf.image.decode_jpeg(value)5.设置图像大小，固定图像通道image_resize=tf.image.image_resize(image,[200,200])image_resize.set_shape([200,200,3])6.批处理tf.train.batch([image_resize],batch_size=20,num_threads=2,capacity=20)7.使用tf.Session()作为sess打开会话处理：coord=tf.train.Coordinator()threads=tf.train.start_queue_runners(sess,coord=coord)print(sess.run(batch_image))coord.request_stop()coord...key,value=reader.read(image_queue)#解码图像=tf.image.decode_jpeg(value)#处理图像大小image_resize=tf.image.resize_images(image,[200,200])#固定图像矩阵大小image_resize.set_shape([200,200,3])#批处理batch_image=tf.train.batch([image_resize],batch_size=20,num_threads=4,capacity=20)returnbatch_imageif__name__=='__main__':#读取文件路径='./data/image'file_names=os.listdir(path)file_list=[os.path.join(path,filename)forfilenameinfile_names]batch_image=Image_reader(file_list)#Opensessionwithtf.Session()assess:#Openthreadcoordinatorcoord=tf.train.Coordinator()#启动线程processingthreads=tf.train.start_queue_runners(sess,coord=coord)print(sess.run(batch_image))#停止线程coord.request_stop()coord.join(threads)
