Python多线程学习-壹-threading

haoman

Python多线程学习-threading

 

想学习python多线程，可以直接看官网http://docs.python.org/2/library/threading.html
　　       Python的文档真心是值得称赞的，不过你如果不想看英文，直接向入门python多线程，本文可以作为你快速入门的捷径。
先打开python command端口，输入
 

import threading
 Ok，如果没有什么输出，那么就是import成功了。
根据学习的过程并且你如果看过上一篇文章的话，先来下dir命令
 

dir(threading)
BoundedSemaphore
Condition
Event
Lock
RLock
Semaphore
Thread
ThreadError
Timer
　　 这些是threading包提供的一些多线程模块，看到其中的Thread，有没有感觉很眼熟。
这个Thread对于Java的同学来说是个福音，因为使用这个Thread和Java没有什么不同，至少思路一致。
对于threading模块的这些模块，我们后面都会讲到


threading包除了这些模块外，还提供了一些方法，
 
 

threading.enumerate()
返回当前存活的Thread列表
threading.active_count()
threading.activeCount()
返回当前的依然存活的Thread数量，实际上就是enumerate()返回的长度
threading.current_thread()
threading.current_Thread()
返回当前的线程，根据调用线程的不同返回不同值
threading.local
表示thread-local量，Thread-Local数据是跟Thread相关的

 上面这些都是和threading包的内容，实际是保存了当前main thread的宏观信息，明白这个就好。


 
下面我们来学习Thread模块，按照惯例，执行dir命令
 

dir(threading.Thread)
daemon
getName
ident
isAlive
isDaemon
is_alive
join
name
run
setDaemon
setName
start
 
 
　　可以看到，Thread有几个重要的属性，daemon、name、alive、ident
　　daemon：这个参数很关键。在调用start前设置改值，默认主线程创建的子线程都是False，表示主线程必须等子线程完成才能退出；如果为True的话，主线程退出导致子线程立即退出，根据自己的应用场景设置合适的True或者False。
　　name：thread name
　　alive：ture or false
　　ident：identity
　　

　　      看到run和join方法了吗？这个有没有很熟悉。下面我们来看下通过继承threading.Thread 来创建线程的方法。

#!/usr/bin/python
import threading
import time
class my_thread(threading.Thread):
def __init__(self,threadname,interval):
threading.Thread.__init__(self,name=threadname)
self.interval=interval
def run(self):
print dir(self)
for i in range(10):
print self.getName,i
time.sleep(self.interval)

if __name__ == "__main__":
mythread=my_thread("thread one",3)
mythread2=my_thread("thread two",5)
mythread.start()
mythread2.start()
 　　下面我们再看下用另一种方法来创建线程的方法

#!/usr/bin/python
import threading
import time
def run(interval):
for i in range(5):
print threading.current_thread().getName(),i
time.sleep(interval)

if __name__ == "__main__":
for i in range(3):
threading.Thread(target=run,args=[5],name='thread-' + str(i)).start()
 　　对于这种方法创建的线程，我们看下init函数：

 

def __init__(self, group=None, target=None, name=None, args=(), kwargs={})
　　group：预留
　　target：是一个可调用对象（也称为活动[activity]），在线程启动后执行；
　　name：是线程的名字。默认值为“Thread-N“，N是一个数字。
　　args和kwargs：表示调用target时的参数列表和关键字参数。

 

　　看使用方法，应该是使用第一种更为方便
　　

　　我们先看下daemon的用法：

import threading
import datetime
from time import sleep
import sys
class threadclass(threading.Thread):
def run(self):
print self.daemon
for i in range(10):
now=datetime.datetime.now()
print "%s says hello world at  time:%s" %(self.getName(),now)
sleep(1)
if __name__ == "__main__":
t=threadclass();
t.daemon=True
t.start()
sleep(5)
sys.exit(0)
 

 

可以看到执行了五次后就退出了，主线程推出子线程也就退出了。

可以再将t.daemon=True注掉后再运行一下，对比下结果。

 

关于join的用法，如果在主线程中调用这个方法，会等子线程执行完成后主线程才会退出来。

这个join用法和daemon参数是有冲突的，不过一般不会同时设置daemon参数和调用join方法

有了Thread结构，后面的工作就很简单啦。

下面我们再看下threading.Timer的用法。

 

#!/usr/bin/python
import threading
import time
def run():
print "hello word";
if __name__ == "__main__":
t=threading.Timer(5.0,run)
t.start()
 

 

Timer的用法比较简单，就是设定一个时间点interval，等到时间间隔到了后，执行function

并没有想你想象的那么大的功能，如Java的Timer、Quartz的Scheduler等。

这个Timer的功能从初始化函数可以看出来：

 

 

def __init__(self, interval, function, args=[], kwargs={}):
interval：时间间隔
function：执行函数
args、kwargs：函数执行参数
 

 

 

本节我们学习了Thread、Timer两个模型，下节课我们学习别的内容