Python3中多线程编程的队列运作示例
作者:goldensun 时间:2022-06-15 23:27:49
Python3,开一个线程,间隔1秒把一个递增的数字写入队列,再开一个线程,从队列中取出数字并打印到终端
#! /usr/bin/env python3
import time
import threading
import queue
# 一个线程,间隔一定的时间,把一个递增的数字写入队列
# 生产者
class Producer(threading.Thread):
def __init__(self, work_queue):
super().__init__() # 必须调用
self.work_queue = work_queue
def run(self):
num = 1
while True:
self.work_queue.put(num)
num = num+1
time.sleep(1) # 暂停1秒
# 一个线程,从队列取出数字,并显示到终端
class Printer(threading.Thread):
def __init__(self, work_queue):
super().__init__() # 必须调用
self.work_queue = work_queue
def run(self):
while True:
num = self.work_queue.get() # 当队列为空时,会阻塞,直到有数据
print(num)
def main():
work_queue = queue.Queue()
producer = Producer(work_queue)
producer.daemon = True # 当主线程退出时子线程也退出
producer.start()
printer = Printer(work_queue)
printer.daemon = True # 当主线程退出时子线程也退出
printer.start()
work_queue.join() # 主线程会停在这里,直到所有数字被get(),并且task_done(),因为没有调用task_done(),所在这里会一直阻塞,直到用户按^C
if __name__ == '__main__':
main()
queue是线程安全的,从多个线程访问时无需加锁。
如果在work_queue.get()之后调用work_queue.task_done(),那么在队列空时work_queue.join()会返回。
这里work_queue.put()是间隔一定时间才往队列放东西,如果调用work_queue.task_done(),在数字1被get()后,队列空时,join()就返回,程序就结束了。
也就是程序只打印了1然后就退出了。
所以在这种使用情景下,不能调用task_done(),程序会一直循环下去。
标签:Python,线程
0
投稿
猜你喜欢
Python map和reduce函数用法示例
2022-06-21 09:02:25
pytorch1.0中torch.nn.Conv2d用法详解
2023-07-17 10:53:48
基于go手动写个转发代理服务的代码实现
2024-04-25 15:11:15
关于PyTorch中nn.Module类的简介
2023-03-19 13:31:15
Numpy随机抽样的实现
2022-06-24 07:18:02
SQLServer Execpt和not in 性能区别
2024-01-21 23:33:46
Python写的Tkinter程序屏幕居中方法
2022-08-03 17:53:07
MySQL 创建索引(Create Index)的方法和语法结构及例子
2024-01-25 22:57:19
php ZipArchive解压缩实现后台管理升级问题详解
2023-05-25 11:58:10
ASP利用XMLHTTP实现表单提交以及cookies的发送的代码
2011-04-15 10:37:00
JS如何实现在弹出窗口中加载页面
2024-04-29 14:07:53
python中random模块详解
2023-07-30 02:29:23
使用rpclib进行Python网络编程时的注释问题
2022-12-26 23:44:47
SaaS中的用户体验设计
2009-05-20 12:28:00
Python单例模式的两种实现方法
2023-03-03 12:31:09
sql中时间以5分钟半个小时任意间隔分组的实现方法
2024-01-25 04:23:39
一文详解Python中itertools模块的使用方法
2022-11-11 06:12:50
Python程序控制语句用法实例分析
2021-04-13 06:59:48
django 实现电子支付功能的示例代码
2022-01-31 01:30:34
Django开发RESTful API实现增删改查(入门级)
2022-05-17 02:36:53