多线程介绍和多线程模块

线程的特点：

线程的生命周期

开始

运行

结束

线程的退出：

进程执行完成

线程的退出方法

python的系统推出

模块函数

start_new_thread(func, args) #(func,(name,i))

allocate_lock()

exit()

[root@133managehosts]#vimthread01.py#!/usr/bin/envpython#encoding:utf8importthreadimporttimedeffunc(name,i):forninxrange(i):printname,ntime.sleep(1)thread.start_new_thread(func,('声音',3))#(func,(name,i))thread.start_new_thread(func,('画面',3))time.sleep(3)[root@133managehosts]#pythonthread01.py声音0画面0声音1画面1声音2画面2

LockType对象方法

lock= thread.allocate_lock() 生成锁对象

lock.acquire() 加锁

lock.locked() 查看锁状态

lock.release() 多线程调度释放锁，使用前线程必须已经获得锁定，否则将抛出异常

[root@133managehosts]#vimthread01.py#!/usr/bin/envpython#encoding:utf8importthreadimporttimedeffunc(name,i,l):forninxrange(i):printname,ntime.sleep(1)l.release()＃release解锁lock=thread.allocate_lock()＃申请一把锁lock.acquire()＃获取并使用这把锁thread.start_new_thread(func,('声音',5,lock))thread.start_new_thread(func,('画面',5,lock))whilelock.locked():#这是主进程，lock.locked=True，执行pass,主进程一直处于锁定状态，线程执行，直到线程执行完毕，释放锁，lock.locked=Falsepassprintlock.locked()#解锁后，值为Falseprint"Exitmainprocess"[root@133managehosts]#pythonthread01.py声音画面00画面1声音1画面2声音2画面3声音3画面4声音4FalseExitmainprocess[root@133managehosts]#vimthread02.py#!/usr/bin/envpythonimportthreadimporttimedefprintworld():foriinrange(5):ifw_lock.acquire():print'world',time.ctime()h_lock.release()h_lock=thread.allocate_lock()w_lock=thread.allocate_lock()thread.start_new_thread(printworld,())w_lock.acquire()foriinrange(5):ifh_lock.acquire():print'hello',w_lock.release()time.sleep(1)[root@133managehosts]#pythonthread02.pyhelloworldFriFeb1020:26:512017helloworldFriFeb1020:26:512017helloworldFriFeb1020:26:512017helloworldFriFeb1020:26:512017helloworldFriFeb1020:26:512017[root@133managehosts]#vimthread02.py#!/usr/bin/envpythonimportthreadimporttimedefprintworld():foriinrange(5):ifw_lock.acquire():＃申请world锁，ifTrue为真print'world',time.ctime()＃打印worldh_lock.release()＃释放hello锁h_lock=thread.allocate_lock()w_lock=thread.allocate_lock()thread.start_new_thread(printworld,())＃开启的线程，和主进程并列执行。w_lock.acquire()＃获得world锁foriinrange(5):ifh_lock.acquire():＃申请hello锁，ifTrue为真print'hello',＃打印hellow_lock.release()＃释放world锁whileh_lock.locked():#这是主进程，直到hello打印5次后才释放。pass[root@133managehosts]#pythonthread02.pyhelloworldFriFeb1020:29:482017helloworldFriFeb1020:29:482017helloworldFriFeb1020:29:482017helloworldFriFeb1020:29:482017helloworldFriFeb1020:29:482017

申请了锁之后，会执行thread.start_new_thread(func,('声音',5,lock))和thread.start_new_thread(func,('画面',5,lock))这两行代码的。

执行他们的时候，同时也会执行主进程里的while的。主进程与这两个线程是同时执行的。为了不让线程退出，所以在主进程里有while来判断锁是不是已经释放了，如果是释放了，说明线程执行完了。

使用主线程控制，线程打印hello和world

[root@133managehosts]#vimthread03.py+22#!/usr/bin/envpythonimportthreadimporttimedefhello():foriinxrange(5):h_lock.acquire()print'hello',w_lock.release()defworld():foriinxrange(5):w_lock.acquire()print'world',time.ctime()h_lock.release()lock.release()＃释放主线程的的锁lock=thread.allocate_lock()#为主进程申请锁lock.acquire()＃主进程获得锁h_lock=thread.allocate_lock()＃为hello线程申请一把锁w_lock=thread.allocate_lock()＃为world线程申请一把锁w_lock.acquire()＃world线程获取锁thread.start_new_thread(hello,())＃启动线程hellothread.start_new_thread(world,())＃启动线程world#time.sleep(1)whilelock.locked():＃当主线程的锁的状态为true时pass＃什么都不做＃hello和world的两个线程是同时运行的[root@133managehosts]#pythonthread03.pyhelloworldTueFeb1414:59:112017helloworldTueFeb1414:59:112017helloworldTueFeb1414:59:112017helloworldTueFeb1414:59:112017helloworldTueFeb1414:59:112017

从脚本的执行顺序，hello()这个函数先执行，输出hello，
然后把world的锁释放（w_lock.release()）。
world()函数获得锁，输出world，然后把hello的锁释放。
必须释放对方的锁，对方才能获得锁（h_lock.acquire()），如果对方的锁没有被释放，那么对方再想获得锁是不成功的，会一直处于阻塞状态，直到锁被释放。

hello()函数第一次获得了锁资源（h_lock.acquire()），打印了hello，接着释放了world的锁资源（w_lock.release()）。
world()函数获得了锁资源（w_lock.acquire()），打印了world，接着释放了hello的锁资源（h_lock.release()）。
由于hello的锁资源被释放了，hello函数里又获得了锁资源，接着第二次打印hello。
也就是说哪个函数或得了锁资源，就会打印相应的信息。
锁资源只有被释放了，下一次才能获得，即已经获得了锁资源，不能再次获得，所以在hello函数里释放world的锁资源，在world函数里才能获得锁资源。
这样反反复复，就打印了hello world。

threading

threading不需要进程的控制来控制线程

threading.Thread:类

成员方法：

start() 启动线程

run() 可以重写

join() 阻塞

getName()

setName()

isDaemon()判断线程是否随主线程一起结束

setDaemon设置线程与主线程一起结束

In[1]:importthreadingIn[2]:help(threading.Thread)HelponclassThreadinmodulethreading:classThread(_Verbose)|Methodresolutionorder:|Thread|_Verbose|__builtin__.object||Methodsdefinedhere:||__init__(self,group=None,target=None,name=None,args=(),kwargs=None,verbose=None)

[root@133managehosts]#vimthreading01.py#!/usr/bin/envpythonimportthreadingimporttimedeffunc():print'hello',time.ctime()time.sleep(1)if__name__=='__main__':foriinxrange(10):t=threading.Thread(target=func,args=())t.start()print'complete'[root@133managehosts]#pythonthreading01.pyhelloTueFeb1415:42:102017＃瞬间打印10行helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017complete

如果添加t.join,则会阻塞，每秒打印一次，上一个阻塞执行完才会执行下一个

deffunc():print'hello',time.ctime()time.sleep(1)if__name__=='__main__':foriinxrange(10):t=threading.Thread(target=func,args=())t.start()t.join()[root@133managehosts]#pythonthreading01.pyhelloTueFeb1415:42:102017#每隔一秒打印一次helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017helloTueFeb1415:42:102017complete

[root@133managehosts]#vimthreading02.py#!/usr/bin/envpython#encoding:utf8importthreadingimporttimedeffunc(name,i):forninxrange(i):printname,ntime.sleep(1)t1=threading.Thread(target=func,args=('声音',3))t2=threading.Thread(target=func,args=('画面',3))t1.start()t2.start()[root@133managehosts]#pythonthreading02.py声音0画面0声音1画面1声音2画面2如果添加一个t1.join()，则会先打印t1，然后再打印t2t1.start()t1.join()t2.start()结果变为：[root@133managehosts]#pythonthreading02.py声音0声音1声音2画面0画面1画面2

t1.setDaemon(True) 设置t1线程和主进程一起退出

[root@133managehosts]#vimthreading02.py#!/usr/bin/envpython#encoding:utf8importthreadingimporttimedeffunc(name,i):forninxrange(i):printname,ntime.sleep(1)t1=threading.Thread(target=func,args=('声音',3))t2=threading.Thread(target=func,args=('画面',3))t1.setDaemon(True)＃设置t1线程和主进程一起退出t1.start()＃开启t1线程，打印一次就会退出，因为主进程已经退出t2.setDaemon(True)t2.start()[root@133managehosts]#pythonthreading02.py声音0画面0

互斥锁

[root@133managehosts]#pwd/opt/python/managehosts[root@133managehosts]#catthreading07.py#!/usr/bin/envpythonimportthreadingimporttimedefhello():foriinxrange(5):h_lock.acquire()print'hello',w_lock.release()defworld():foriinxrange(5):w_lock.acquire()print'world',time.ctime()h_lock.release()h_lock=threading.Lock()w_lock=threading.Lock()w_lock.acquire()t1=threading.Thread(target=hello,args=())t2=threading.Thread(target=world,args=())t1.start()t2.start()[root@133managehosts]#pythonthreading07.pyhelloworldWedMar2911:51:592017helloworldWedMar2911:51:592017helloworldWedMar2911:51:592017helloworldWedMar2911:51:592017helloworldWedMar2911:51:592017

#!/usr/bin/pythonimportthreadimporttimedefhello():foriinxrange(5):h_lock.acquire()print'hello',w_lock.release()defworld():foriinxrange(5):w_lock.acquire()print'world'h_lock.release()lock.release()lock=thread.allocate_lock()lock.acquire()h_lock=thread.allocate_lock()w_lock=thread.allocate_lock()w_lock.acquire()thread.start_new_thread(hello,())thread.start_new_thread(world,())whilelock.locked():pass

程序执行开两个线程，即hello和world。

执行hello线程时，只有3步：

先申请h_lock锁，即h_lock.acquire()

然后输出hello，即print 'hello',

最后释放w_lock锁，即w_lock.release()

执行world线程时也是3步：

申请w_lock锁，即w_lock.acquire()

输出world，即print 'world'

释放h_lock锁，即h_lock.release()

线程是同时执行的，为什么hello和world会交替输出，没有先输出world？

在主线程里，申请了w_lock锁，即26行的w_lock.acquire()，所以在world()函数里的w_lock.acquire()一直

处于阻塞状态，意味着print 'world'这一行是不会执行的，直到hello()函数里把w_lock释放，即w_lock.release()

所以在每个函数里都有释放对方的锁，这样对方就把自己要输出的内容执行了。

最后world函数里的循环执行完了，释放lock这个锁，这样这个主进程也结束了。

[root@133managehosts]#catthreading08.py#!/usr/bin/envpythonimportthreadingimporttimeclassMyThread(threading.Thread):def__init__(self):threading.Thread.__init__(self)defrun(self):globalcountertime.sleep(1)mutex.acquire()＃获得锁counter+=1print"Iam%s,setcounter:%s"%(self.name,counter)mutex.release()＃释放锁if__name__=='__main__':counter=0mutex=threading.Lock()#分配锁foriinxrange(300):t=MyThread()t.start()[root@133managehosts]#pythonthreading08.pyIamThread-1,setcounter:1IamThread-2,setcounter:2IamThread-3,setcounter:3IamThread-4,setcounter:4IamThread-5,setcounter:5IamThread-6,setcounter:6IamThread-7,setcounter:7IamThread-8,setcounter:8IamThread-9,setcounter:9IamThread-10,setcounter:10IamThread-11,setcounter:11IamThread-12,setcounter:12IamThread-13,setcounter:13IamThread-14,setcounter:14IamThread-15,setcounter:15IamThread-284,setcounter:282IamThread-283,setcounter:283IamThread-282,setcounter:284IamThread-285,setcounter:285IamThread-287,setcounter:286IamThread-286,setcounter:287IamThread-288,setcounter:288IamThread-289,setcounter:289IamThread-290,setcounter:290IamThread-293,setcounter:291IamThread-292,setcounter:292IamThread-291,setcounter:293IamThread-295,setcounter:294IamThread-296,setcounter:295IamThread-297,setcounter:296IamThread-294,setcounter:297IamThread-298,setcounter:298IamThread-299,setcounter:299IamThread-300,setcounter:300