Python Threading 学习笔记 | 4、Queue功能
- 2019 年 11 月 5 日
- 笔记
0x00 关于Queue
queue模块实现了各种【多生产者-多消费者】队列，可用于在执行的多个线程之间安全的交换信息。
queue的常用方法
q.size()：返回队列的正确大小。因为其他线程可能正在更新此队列，所以此方法的返回数字不可靠。 q.empty()：如果队列为空，返回True，否则返回False。 q.full()：如果队列已满，返回True，否则返回False。 q.put(item,block,timeout)：将item放入队列。如果block设为True（默认值），调用者将被阻塞直到队列中出现可用的空闲位置为止。如果block设为False，队列满时此方法将引发Full异常。 q.put_nowait(item):等价于q.put(item,False) q.get(block,timeout):从队列中删除一项，然后返回这个项。如果block设为True（默认值），调用者将阻塞，直到队列中出现可用的空闲为止。如果block设为False，队列为空时将引发Empty异常。timeout提供可选的超时值，单位为秒，如果超时，将引发Empty异常。 q.get_nowait()：等价于get(0) q.task_done():在队列中数据的消费者用来指示对于项的处理已经结束。如果使用此方法，那么从队列中删除的每一项都应该调用一次。 q.join()：阻塞直到队列中的所有项均被删除和处理为止。一旦为队列中的每一项都调用了一次q.task_done()方法，此方法将会直接返回。
0x01 本节代码实现功能
将数据列表中的数据传入，使用三个线程处理，将结果保存在Queue中，线程执行完后，从Queue中获取存储的结果。
0x02导入线程,队列的标准模块
import timeimport threadingfrom queue import Queue
0x03 定义一个被多线程调用的函数
该函数的参数是一个列表lists和一个队列q，其功能是对lists列表中的元素除2取整，之后利用q.put()将结果保存在队列q中。
def job(lists,q): # 被调用函数 for i in range(len(lists)): lists[i] = lists[i]//2 # lists元素除2取整 q.put(lists) # 多线程调用的函数不能用return返回值
0x04 定义一个多线程函数
在多线程函数中定义一个Queue用来保存返回值代替return，同时定义一个多线程列表，初始化一个多维数据列表用来传入上面的job()函数。
def multithreading(): # 调用多线程的函数 q = Queue() # 存放job()函数的返回值 thread_list = [] data = [[1],[2,3],[4,5,6]]
定义三个线程，启动线程并分别join三个线程到主线程
for i in range(3): # 定义三个线程 t = threading.Thread(target=job,args=(data[i],q)) t.start() thread_list.append(t) # 将线程添加到thread_list列表中 for thread in thread_list: thread.join()
定义一个空的result_list列表，将队列q中的数据添加到列表中并print
result_list = [] for j in range(3): # 循环三次 result_list.append(q.get()) print(result_list[j])
0x05 完整的代码
import time import threading from queue import Queue def job(lists,q): # 被调用函数 for i in range(len(lists)): lists[i] = lists[i]//2 # lists元素除2取整 q.put(lists) # 多线程调用的函数不能用return返回值 def multithreading(): # 调用多线程的函数 q = Queue() # 存放job()函数的返回值 thread_list = [] data = [[1],[2,3],[4,5,6]] for i in range(3): # 定义三个线程 t = threading.Thread(target=job,args=(data[i],q)) t.start() thread_list.append(t) # 将线程添加到thread_list列表中 for thread in thread_list: thread.join() result_list = [] for j in range(3): # 循环三次 result_list.append(q.get()) print(result_list[j]) if __name__ == '__main__': multithreading()
运行结果：
# python 4_queue.py [0] [1, 1] [2, 2, 3]
代码项目地址：https://github.com/teamssix/Python-Threading-study-notes 参考文章： https://segmentfault.com/a/1190000016330288 https://morvanzhou.github.io/tutorials/python-basic/threading
