Python多線程和隊(duì)列操作實(shí)例
Python3,開(kāi)一個(gè)線程,間隔1秒把一個(gè)遞增的數(shù)字寫(xiě)入隊(duì)列,再開(kāi)一個(gè)線程,從隊(duì)列中取出數(shù)字并打印到終端
#! /usr/bin/env python3
import time
import threading
import queue
# 一個(gè)線程,間隔一定的時(shí)間,把一個(gè)遞增的數(shù)字寫(xiě)入隊(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)闆](méi)有調(diào)用task_done(),所在這里會(huì)一直阻塞,直到用戶(hù)按^C
if __name__ == '__main__':
main()
queue是線程安全的,從多個(gè)線程訪問(wèn)時(shí)無(wú)需加鎖。
如果在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)文章
Sklearn調(diào)優(yōu)之網(wǎng)格搜索與隨機(jī)搜索原理詳細(xì)分析
這篇文章主要介紹了Sklearn調(diào)優(yōu)之網(wǎng)格搜索與隨機(jī)搜索原理,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧2023-02-02
詳解Python如何實(shí)現(xiàn)輸出顏色字體到終端界面
在終端中,輸出的字體總是單一顏色的,黑底白字。但是在一些場(chǎng)景并不能很好的滿(mǎn)足輸出的需求。本文為大家介紹了Python如何實(shí)現(xiàn)輸出顏色字體到終端界面中,需要的可以參考一下2022-12-12
python獲得文件創(chuàng)建時(shí)間和修改時(shí)間的方法
這篇文章主要介紹了python獲得文件創(chuàng)建時(shí)間和修改時(shí)間的方法,涉及Python針對(duì)文件屬性的相關(guān)操作技巧,需要的朋友可以參考下2015-06-06
詳解python中靜態(tài)方法staticmethod用法
本文主要介紹了python中靜態(tài)方法staticmethod用法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07
Python接入MySQL實(shí)現(xiàn)增刪改查的實(shí)戰(zhàn)記錄
這篇文章主要給大家介紹了關(guān)于Python接入MySQL實(shí)現(xiàn)增刪改查的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
python+selenium識(shí)別驗(yàn)證碼并登錄的示例代碼
本篇文章主要介紹了python+selenium識(shí)別驗(yàn)證碼并登錄的示例代碼,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-12-12
matplotlib自定義鼠標(biāo)光標(biāo)坐標(biāo)格式的實(shí)現(xiàn)
這篇文章主要介紹了matplotlib自定義鼠標(biāo)光標(biāo)坐標(biāo)格式的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-01-01
Python讀寫(xiě)Excel文件庫(kù)的實(shí)現(xiàn)示例
本文主要介紹了Python讀寫(xiě)Excel文件庫(kù)的實(shí)現(xiàn)示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-08-08

