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