国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

Python多線程隊列示例

2019-11-14 17:17:06
字體:
來源:轉載
供稿:網友

Python3,開一個線程,間隔1秒把一個遞增的數字寫入隊列,再開一個線程,從隊列中取出數字并打印到終端

#! /usr/bin/env python3import timeimport threadingimport 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(),所在這里會一直阻塞,直到用戶按^Cif __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(),程序會一直循環下去。

https://docs.python.org/3/library/queue.html


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 武安市| 临泉县| 平顺县| 厦门市| 册亨县| 溧水县| 青阳县| 苗栗市| 武功县| 泰宁县| 盖州市| 灌南县| 随州市| 雅江县| 白银市| 额尔古纳市| 大名县| 青神县| 浦城县| 祥云县| 东阳市| 独山县| 侯马市| 内黄县| 易门县| 蓝田县| 桐梓县| 屏南县| 浮梁县| 赣榆县| 军事| 湟源县| 霍林郭勒市| 原平市| 湾仔区| 新龙县| 前郭尔| 沙洋县| 四川省| 贵定县| 湖南省|