我对python线程池的理解

#!/usr/bin/env python
from Queue import Queue
from threading import Thread
import random
import time

def person(i,q):
    while True:  #这我的一直处与能够接活干的状态
        q.get()
        print "Thread",i,"do_job"
        time.sleep(random.randint(1,5))#每一个人干活的时间不同,天然就会致使每一个人分配的件数不一样(这里是干活的地方)
        q.task_done()   #接到的活作完了,向上汇报

q=Queue()

分配1000件活
for x in xrange(100):
    q.put(x)

叫了5我的去干活    
for i in xrange(5):
    worker=Thread(target=person,args=(i,q))
    worker.setDaemon(True)
    worker.start()

q.join()  #这5我的把1000件活都作完后,结束.

线程池的概念就是咱们将1000件活,本来由1000我的来作,如今只分配5我的来作,这5我的就是线程池数,而且他们处与一直运行状态,除非主程序结束,不然,将不会结束。
测试:
     咱们现不分配活给他们,看他们处与什么状态.
     注释
     #for x in xrange(100):
     #    q.put(x)
     而且在q.join()后面添加
     time.sleep(120)  主程序2分钟后退出。
     查看:
     root@badboy-virtual-machine:~#ps aux|grep test.py
     root      3907  0.0  0.2  54344  4400 pts/0    Sl+  15:56   0:00 python test.py
    
     root@badboy-virtual-machine:~# pstree -p |grep python
        |-sshd(937)---sshd(2729)-+-bash(2850)---python(3907)-+-{python}(3908)
        |                        |                           |-{python}(3909)
        |                        |                           |-{python}(3910)
        |                        |                           |-{python}(3911)
        |                        |                           `-{python}(3912)
    看到没,虽然他们如今没接到任务,但他们一直处与活动状态,随时接受任务.
python


若是想了解更多,请关注咱们的公众号
公众号ID:opdevos
扫码关注
bash

gongzhouhao.jpg

相关文章
相关标签/搜索