最近在做一個視頻設(shè)備管理的項目，設(shè)備包括（攝像機(jī)，DVR,NVR等），包括設(shè)備信息補(bǔ)全，設(shè)備狀態(tài)推送，設(shè)備流地址推送等，如果同時導(dǎo)入的設(shè)備數(shù)量較多，如果使用單線程進(jìn)行設(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ù)，然后進(jìn)行處理，使用了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é)會詳細(xì)介紹上面的整個流程以及每個函數(shù)：python 線程池threadpool(實現(xiàn)篇)

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