脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 脚本专栏 → python → python线程池threadpool使用

python线程池threadpool使用篇

 更新时间：2018年04月27日 09:12:32   作者：菜鸟磊子  
这篇文章主要为大家详细介绍了python线程池threadpool的使用方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

最近在做一个视频设备管理的项目，设备包括（摄像机，DVR,NVR等），包括设备信息补全，设备状态推送，设备流地址推送等，如果同时导入的设备数量较多，如果使用单线程进行设备检测，那么由于设备数量较多，会带来较大的延时，因此考虑多线程处理此问题。

可以使用python语言自己实现线程池，或者可以使用第三方包threadpool线程池包，本主题主要介绍threadpool的使用以及其里面的具体实现。

1、安装

使用安装:

pip installthreadpool

2、使用

    （1）引入threadpool模块
    （2）定义线程函数
    （3）创建线程 池threadpool.ThreadPool()
    （4）创建需要线程池处理的任务即threadpool.makeRequests()
    （5）将创建的多个任务put到线程池中,threadpool.putRequest
    （6）等到所有任务处理完毕theadpool.pool()

import threadpool 
def ThreadFun(arg1,arg2): 
 pass 
def main(): 
 device_list=[object1,object2,object3......,objectn]#需要处理的设备个数 
 task_pool=threadpool.ThreadPool(8)#8是线程池中线程的个数 
 request_list=[]#存放任务列表 
 #首先构造任务列表 
 for device in device_list: 
 request_list.append(threadpool.makeRequests(ThreadFun,[((device, ), {})])) 
 #将每个任务放到线程池中，等待线程池中线程各自读取任务，然后进行处理，使用了map函数，不了解的可以去了解一下。 
 map(task_pool.putRequest,request_list) 
 #等待所有任务处理完成，则返回，如果没有处理完，则一直阻塞 
 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

下一节会详细介绍上面的整个流程以及每个函数：python 线程池threadpool(实现篇)

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • Python中的图形绘制简单动画实操

    Python中的图形绘制简单动画实操

    这篇文章主要介绍了Python中的图形绘制简单动画实操， Matplotlib 是一个非常广泛的库，它也支持图形动画，动画工具以 matplotlib.animation 基类为中心，它提供了一个框架，围绕该框架构建动画，下面来看看具体的实现过程吧，需要的小伙伴可以参考一下
    2022-02-02
  • python区块链实现简版工作量证明

    python区块链实现简版工作量证明

    这篇文章主要为大家介绍了python区块链实现简版工作量证明详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-05-05
  • 浅析Python实现DFA算法

    浅析Python实现DFA算法

    DFA全称为Deterministic Finite Automaton,即确定有穷自动机。特征：有一个有限状态集合和一些从一个状态通向另一个状态的边，每条边标记有一个符号，其中一个状态是初态，某些状态是终态。不同于不确定的有限自动机，DFA中不会有从同一状态出发的两条边标志有相同的符号
    2021-06-06
  • Python PyQt5模块实现一个浏览器的示例代码

    Python PyQt5模块实现一个浏览器的示例代码

    在项目开发中，有的应用程序可以运行在web浏览器，本文主要介绍了Python PyQt5模块实现一个浏览器的示例代码，分享给大家，感兴趣的可以了解一下
    2021-07-07
  • python使用requests.session模拟登录

    python使用requests.session模拟登录

    最近开发一套接口，写个Python脚本，使用requests.session模拟一下登录.本文通过实例代码给大家介绍python使用requests.session模拟登录，感兴趣的朋友跟随小编一起看看吧
    2019-08-08
  • Python入门教程(十六)Python的if逻辑判断分支

    Python入门教程(十六)Python的if逻辑判断分支

    这篇文章主要介绍了Python入门教程(十六)Python的if逻辑判断分支,Python是一门非常强大好用的语言,也有着易上手的特性,本文为入门教程,需要的朋友可以参考下
    2023-04-04
  • python的数学算法函数及公式用法

    python的数学算法函数及公式用法

    在本篇内容里小编给大家分享了一篇关于python的数学算法函数及公式用法，有兴趣的朋友们可以参考下。
    2020-11-11
  • Python将HTML快速转换成PDF的方法实现

    Python将HTML快速转换成PDF的方法实现

    在Web开发和报告任务中,将HTML内容转换为PDF是一种常见需求,本文主要介绍了Python将HTML快速转换成PDF的方法实现,具有一定的参考价值,感兴趣的可以了解一下
    2024-01-01
  • Python利用subplots_adjust方法解决图表与画布的间距问题

    Python利用subplots_adjust方法解决图表与画布的间距问题

    这篇文章主要介绍了如何在使用python 的 matplotlib库绘图时， 使用subplots_adjust()方法来调整图表与画布之间的间距，以及图表与图表之间的间距，感兴趣的可以了解一下
    2022-04-04
  • 如何使用python3获取当前路径及os.path.dirname的使用

    如何使用python3获取当前路径及os.path.dirname的使用

    这篇文章主要介绍了如何使用python3获取当前路径及os.path.dirname的使用,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12

最新评论