快捷導(dǎo)航

python線程池threadpool使用篇

更新時間：2018年04月27日 09:12:32 作者：菜鳥磊子

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

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

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

1、安裝

使用安裝:

pip installthreadpool

2、使用

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

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

上面就是一個具體的線程池的使用流程
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é)會詳細介紹上面的整個流程以及每個函數(shù)：python 線程池threadpool(實現(xiàn)篇)

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

您可能感興趣的文章:

相關(guān)文章

tkinter如何實現(xiàn)label超鏈接調(diào)用瀏覽器打開網(wǎng)址
這篇文章主要介紹了tkinter如何實現(xiàn)label超鏈接調(diào)用瀏覽器打開網(wǎng)址問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-01-01
Python PIL圖片如何按比例裁剪
這篇文章主要介紹了Python PIL圖片如何按比例裁剪，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2022-05-05
Django實現(xiàn)學(xué)生管理系統(tǒng)
這篇文章主要為大家詳細介紹了Django實現(xiàn)學(xué)生管理系統(tǒng)，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2019-02-02
Python 樹表查找（二叉排序樹、平衡二叉樹）
本文并不會深入講解樹數(shù)據(jù)結(jié)構(gòu)的基本的概念，僅是站在使用的角度說清楚動態(tài)查詢。閱讀此文之前，請預(yù)備一些樹的基礎(chǔ)知識。
2023-01-01
Python中try用法、內(nèi)置異常類型與自定義異常類型拓展案例詳解
在?Python?里,try?語句主要用于異常處理,其作用是捕獲并處理代碼運行期間可能出現(xiàn)的異常,避免程序因異常而意外終止,這篇文章主要介紹了Python中try用法、內(nèi)置異常類型與自定義異常類型拓展,需要的朋友可以參考下
2025-04-04
Python利用PyPDF2庫合并多個pdf文件
PyPDF2庫是一個用于處理PDF文件的Python庫，它提供了一系列的工具來讀取、編輯、合并、拆分和加密PDF文件，使得我們可以在Python環(huán)境下輕松地對PDF文件進行操作，本文將帶大家介紹如何通過Python的PyPDF2庫合并多個pdf文件,需要的朋友可以參考下
2023-05-05
Pandas?DataFrame添加一行數(shù)據(jù)的幾種方法
在處理數(shù)據(jù)分析和數(shù)據(jù)科學(xué)項目時,經(jīng)常會使用到Python中的pandas庫來進行數(shù)據(jù)操作和分析,其中DataFrame是pandas庫中最重要的數(shù)據(jù)結(jié)構(gòu)之一,這篇文章主要給大家介紹了關(guān)于Pandas?DataFrame添加一行數(shù)據(jù)的幾種方法,需要的朋友可以參考下
2024-08-08
Python類super()及私有屬性原理解析
這篇文章主要介紹了Python類super()及私有屬性原理解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
2020-06-06
python中正則表達式findall的用法實例
在寫著自動化測試的腳本時重新復(fù)習(xí)了一下正則表達式findall()方法,下面這篇文章主要給大家介紹了關(guān)于python中正則表達式findall用法的相關(guān)資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下
2022-09-09
python接入支付寶的實例操作
在本篇文章里小編給大家整理的是一篇關(guān)于python接入支付寶的實例操作內(nèi)容，需要的朋友們可以學(xué)習(xí)下。
2020-07-07