快捷導(dǎo)航

python線(xiàn)程池threadpool使用篇

更新時(shí)間：2018年04月27日 09:12:32 作者：菜鳥(niǎo)磊子

這篇文章主要為大家詳細(xì)介紹了python線(xiàn)程池threadpool的使用方法，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

最近在做一個(gè)視頻設(shè)備管理的項(xiàng)目，設(shè)備包括（攝像機(jī)，DVR,NVR等），包括設(shè)備信息補(bǔ)全，設(shè)備狀態(tài)推送，設(shè)備流地址推送等，如果同時(shí)導(dǎo)入的設(shè)備數(shù)量較多，如果使用單線(xiàn)程進(jìn)行設(shè)備檢測(cè)，那么由于設(shè)備數(shù)量較多，會(huì)帶來(lái)較大的延時(shí)，因此考慮多線(xiàn)程處理此問(wèn)題。

可以使用python語(yǔ)言自己實(shí)現(xiàn)線(xiàn)程池，或者可以使用第三方包threadpool線(xiàn)程池包，本主題主要介紹threadpool的使用以及其里面的具體實(shí)現(xiàn)。

1、安裝

使用安裝:

pip installthreadpool

2、使用

    （1）引入threadpool模塊
    （2）定義線(xiàn)程函數(shù)
    （3）創(chuàng)建線(xiàn)程池threadpool.ThreadPool()
    （4）創(chuàng)建需要線(xiàn)程池處理的任務(wù)即threadpool.makeRequests()
    （5）將創(chuàng)建的多個(gè)任務(wù)put到線(xiàn)程池中,threadpool.putRequest
    （6）等到所有任務(wù)處理完畢theadpool.pool()

import threadpool 
def ThreadFun(arg1,arg2): 
 pass 
def main(): 
 device_list=[object1,object2,object3......,objectn]#需要處理的設(shè)備個(gè)數(shù) 
 task_pool=threadpool.ThreadPool(8)#8是線(xiàn)程池中線(xiàn)程的個(gè)數(shù) 
 request_list=[]#存放任務(wù)列表 
 #首先構(gòu)造任務(wù)列表 
 for device in device_list: 
 request_list.append(threadpool.makeRequests(ThreadFun,[((device, ), {})])) 
 #將每個(gè)任務(wù)放到線(xiàn)程池中，等待線(xiàn)程池中線(xiàn)程各自讀取任務(wù)，然后進(jìn)行處理，使用了map函數(shù)，不了解的可以去了解一下。 
 map(task_pool.putRequest,request_list) 
 #等待所有任務(wù)處理完成，則返回，如果沒(méi)有處理完，則一直阻塞 
 task_pool.poll() 
if __name__=="__main__": 
 main()

上面就是一個(gè)具體的線(xiàn)程池的使用流程
threadpool具體的定義如下：

class ThreadPool: 
 """A thread pool, distributing work requests and collecting results. 
 
 See the module docstring for more information. 
 
 """ 
 def __init__(self, num_workers, q_size=0, resq_size=0, poll_timeout=5): 
 pass 
 def createWorkers(self, num_workers, poll_timeout=5): 
 pass 
 def dismissWorkers(self, num_workers, do_join=False): 
 pass 
 def joinAllDismissedWorkers(self): 
 pass 
 def putRequest(self, request, block=True, timeout=None): 
 pass 
 def poll(self, block=False): 
 pass 
 def wait(self): 
 pass

下一節(jié)會(huì)詳細(xì)介紹上面的整個(gè)流程以及每個(gè)函數(shù)：python 線(xiàn)程池threadpool(實(shí)現(xiàn)篇)

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

Python中的圖形繪制簡(jiǎn)單動(dòng)畫(huà)實(shí)操
這篇文章主要介紹了Python中的圖形繪制簡(jiǎn)單動(dòng)畫(huà)實(shí)操，?Matplotlib?是一個(gè)非常廣泛的庫(kù)，它也支持圖形動(dòng)畫(huà)，動(dòng)畫(huà)工具以?matplotlib.animation?基類(lèi)為中心，它提供了一個(gè)框架，圍繞該框架構(gòu)建動(dòng)畫(huà)，下面來(lái)看看具體的實(shí)現(xiàn)過(guò)程吧，需要的小伙伴可以參考一下
2022-02-02
python區(qū)塊鏈實(shí)現(xiàn)簡(jiǎn)版工作量證明
這篇文章主要為大家介紹了python區(qū)塊鏈實(shí)現(xiàn)簡(jiǎn)版工作量證明詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2022-05-05
淺析Python實(shí)現(xiàn)DFA算法
DFA全稱(chēng)為Deterministic Finite Automaton,即確定有窮自動(dòng)機(jī)。特征：有一個(gè)有限狀態(tài)集合和一些從一個(gè)狀態(tài)通向另一個(gè)狀態(tài)的邊，每條邊標(biāo)記有一個(gè)符號(hào)，其中一個(gè)狀態(tài)是初態(tài)，某些狀態(tài)是終態(tài)。不同于不確定的有限自動(dòng)機(jī)，DFA中不會(huì)有從同一狀態(tài)出發(fā)的兩條邊標(biāo)志有相同的符號(hào)
2021-06-06
Python PyQt5模塊實(shí)現(xiàn)一個(gè)瀏覽器的示例代碼
在項(xiàng)目開(kāi)發(fā)中，有的應(yīng)用程序可以運(yùn)行在web瀏覽器，本文主要介紹了Python PyQt5模塊實(shí)現(xiàn)一個(gè)瀏覽器的示例代碼，分享給大家，感興趣的可以了解一下
2021-07-07
python使用requests.session模擬登錄
最近開(kāi)發(fā)一套接口，寫(xiě)個(gè)Python腳本，使用requests.session模擬一下登錄.本文通過(guò)實(shí)例代碼給大家介紹python使用requests.session模擬登錄，感興趣的朋友跟隨小編一起看看吧
2019-08-08
Python入門(mén)教程(十六)Python的if邏輯判斷分支
這篇文章主要介紹了Python入門(mén)教程(十六)Python的if邏輯判斷分支,Python是一門(mén)非常強(qiáng)大好用的語(yǔ)言,也有著易上手的特性,本文為入門(mén)教程,需要的朋友可以參考下
2023-04-04
python的數(shù)學(xué)算法函數(shù)及公式用法
在本篇內(nèi)容里小編給大家分享了一篇關(guān)于python的數(shù)學(xué)算法函數(shù)及公式用法，有興趣的朋友們可以參考下。
2020-11-11
Python將HTML快速轉(zhuǎn)換成PDF的方法實(shí)現(xiàn)
在Web開(kāi)發(fā)和報(bào)告任務(wù)中,將HTML內(nèi)容轉(zhuǎn)換為PDF是一種常見(jiàn)需求,本文主要介紹了Python將HTML快速轉(zhuǎn)換成PDF的方法實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下
2024-01-01
Python利用subplots_adjust方法解決圖表與畫(huà)布的間距問(wèn)題
這篇文章主要介紹了如何在使用python?的?matplotlib庫(kù)繪圖時(shí)，?使用subplots_adjust()方法來(lái)調(diào)整圖表與畫(huà)布之間的間距，以及圖表與圖表之間的間距，感興趣的可以了解一下
2022-04-04
如何使用python3獲取當(dāng)前路徑及os.path.dirname的使用
這篇文章主要介紹了如何使用python3獲取當(dāng)前路徑及os.path.dirname的使用,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2019-12-12