pip installthreadpool

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() 

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