Python多線程和隊列操作實例
Python3，開一個線程，間隔1秒把一個遞增的數(shù)字寫入隊列，再開一個線程，從隊列中取出數(shù)字并打印到終端
#! /usr/bin/env python3
import time
import threading
import queue
# 一個線程，間隔一定的時間，把一個遞增的數(shù)字寫入隊列
# 生產(chǎn)者
class Producer(threading.Thread):
def __init__(self, work_queue):
super().__init__() # 必須調(diào)用
self.work_queue = work_queue
def run(self):
num = 1
while True:
self.work_queue.put(num)
num = num+1
time.sleep(1) # 暫停1秒
# 一個線程，從隊列取出數(shù)字，并顯示到終端
class Printer(threading.Thread):
def __init__(self, work_queue):
super().__init__() # 必須調(diào)用
self.work_queue = work_queue
def run(self):
while True:
num = self.work_queue.get() # 當(dāng)隊列為空時，會阻塞，直到有數(shù)據(jù)
print(num)
def main():
work_queue = queue.Queue()
producer = Producer(work_queue)
producer.daemon = True # 當(dāng)主線程退出時子線程也退出
producer.start()
printer = Printer(work_queue)
printer.daemon = True # 當(dāng)主線程退出時子線程也退出
printer.start()
work_queue.join() # 主線程會停在這里，直到所有數(shù)字被get()，并且task_done()，因為沒有調(diào)用task_done()，所在這里會一直阻塞，直到用戶按^C
if __name__ == '__main__':
main()
queue是線程安全的，從多個線程訪問時無需加鎖。
如果在work_queue.get()之后調(diào)用work_queue.task_done()，那么在隊列空時work_queue.join()會返回。
這里work_queue.put()是間隔一定時間才往隊列放東西，如果調(diào)用work_queue.task_done()，在數(shù)字1被get()后，隊列空時，join()就返回，程序就結(jié)束了。
也就是程序只打印了1然后就退出了。
所以在這種使用情景下，不能調(diào)用task_done()，程序會一直循環(huán)下去。
https://docs.python.org/3/library/queue.html
相關(guān)文章
淺談Python中函數(shù)的定義及其調(diào)用方法
今天小編就為大家分享一篇淺談Python中函數(shù)的定義及其調(diào)用方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2019-07-07
在Python上基于Markov鏈生成偽隨機(jī)文本的教程
這篇文章主要介紹了在Python上基于Markov鏈生成偽隨機(jī)文本的教程,是一個基于馬爾可夫算法的小實現(xiàn),充分體現(xiàn)了Python在科學(xué)計算中的用途,需要的朋友可以參考下2015-04-04
這篇文章主要介紹了python之pkl文件的用法及說明，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-06-06
這篇文章主要介紹了Python接口自動化測試的實現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
Python函數(shù)默認(rèn)參數(shù)常見問題及解決方案
這篇文章主要介紹了Python函數(shù)默認(rèn)參數(shù)常見問題及解決方案,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-03-03
基于Python實現(xiàn)簡單的人臉識別系統(tǒng)
這篇文章主要介紹了如何通過Python實現(xiàn)一個簡單的人臉識別系統(tǒng)，文中的示例代碼講解詳細(xì)，對我們學(xué)習(xí)Python有一定的幫助，感興趣的可以跟隨小編一起試一試2022-01-01
flask?route對協(xié)議作用及設(shè)計思路
這篇文章主要為大家介紹了flask?route對協(xié)議作用及設(shè)計思路詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-07-07
正則表達(dá)式是對字符串操作的一種邏輯公式，正則表達(dá)式是一種文本模式，該模式描述在搜索文本時要匹配的一個或多個字符串。本文重點給大家介紹Python 正則表達(dá)式大全，感興趣的朋友一起看看吧2021-11-11
本文主要介紹了python實現(xiàn)斷點調(diào)試的方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02
python中用Scrapy實現(xiàn)定時爬蟲的實例講解
在本篇文章里小編給大家整理的是一篇關(guān)于python中用Scrapy實現(xiàn)定時爬蟲的實例講解內(nèi)容，有興趣的朋友們可以學(xué)習(xí)下。2021-01-01