锐客网

  1. 首页 > 生活百科 > >

python创建线程池，python里怎么创建线程

经验分享生活百科

1 ， python里怎么创建线程threadingthreading.Thread
2，python中如何创建并开启一个线程使用线程池：threadpool 模块 。这是一个第三方模块 ， 可以通过下面方法安装：easy_install threadpoola=[]a.add("1")a.add("hi")print a##结果: ["1","hi"]
3，python进程池怎么实现当进程池中任务队列非空时 ， 才会触发worker进程去工作，那么如何向进程池中的任务队列中添加任务呢，进程池类有两组关键方法来创建任务，分别是apply/apply_async和map/map_async实际上进程池类的apply和map方法与python内建的两个同名方法类似，apply_async和map_async分别为它们的非阻塞版本 。import psutilp = psutil.process(pid)p.suspend()#挂起进程p.resume()#恢复进程也可以使用input()或者 os.system("pause")【python创建线程池，python里怎么创建线程】
4，python 爬虫加入线程池问题大致思路就是下面了 ， 如果这都看不懂，转行吧 。import threadingimport Queueclass MyThread(threaing.Thread): def __init__(self, queue, name=None): self._queue = queue if name: self.name = name pass def run(self): while q.empty(): passqueue = Queue()for i in xrange(100): queuq.put(i)threads = []for i in xrange(10): threads.append(MyThread(queue, str(i)))for i in threads: i.start()5 ， 如何写线程池因工作需要，需要写一个简单的线程池，一开始觉得无从下手，待慢慢理清思路，写代码就很顺利了，先将这个线程池实现思路简单的贴一下 ， 主要有init_pool(), rounted(), add_work(), void *woke(),destory_pool()等函数：init_pool():完成线程池的初始化工作 。主要工作有：初始化任务队列，初始化锁，初始化条件锁 ， 初始化线程，并给线程注册rounted（）函数，使各线程执行rounted函数 。rouned() ：各个线程创建后执行此函数，此函数中是一个死循环，线程进入循环后 ， 先判断是否有任务，有则将任务从任务队列中取出执行(任务中含有要执行的函数指针即void *woke()和相关参数)，任务数减一，没有任务则阻塞住 ， 等待有任务时触发条件锁然后继续执行该任务 。add_work():此函数是向任务队列中添加任务，即添加线程实际执行的函数指针以及该函数指针需要的参数，任务数加一 。void *woke():此函数指针是我们实际需要执行的函数 ， 定义为指针是方便向线程传递 。destory_pool()：此函数的主要是销毁线程池，等待子线程结束后，销毁各种资源 。上述是一个简单的线程池的实现 ， 理清了思路，写代码就不是问题了 。Ps：学会积累，学会沉淀 。

    推荐阅读


    上一篇：层次分析法 教程,spss层次分析法教程

    下一篇：平板电脑怎么打开，怎样打开平板电脑