单线程
任务多的时候,一件一件做,排个先后。一个任务没有完成的时候,不能开始新任务。
import threading
from time import ctime,sleep
def music(func):
for i in range(2):
print "Play Music %s. %s" %(func,ctime())
sleep(1)
def movie(func):
for i in range(2):
print "Play Movie %s! %s" %(func,ctime())
sleep(5)
if __name__ == '__main__':
music(u'幸福的孩子爱唱歌')
movie(u'丁丁历险记')
print "all over %s" %ctime()
多线程
同时开展多个任务。
python提供了两个模块来实现多线程:thread 和threading。threading通过对thread模块进行二次封装,提供了更方便的API来操作线程。本文只对threading的使用进行说明。
Thread 是threading模块中最重要的类之一,可以使用它来创建线程。有两种方式来创建线程:一种是通过继承Thread类,重写它的run方法;另一种是创建一个threading.Thread对象,在它的初始化函数(__init__)中将可调用对象作为参数传入。
import threading
from time import ctime,sleep
def music(func):
for i in range(2):
print "Play Music %s. %s" %(func,ctime())
sleep(1)
def movie(func):
for i in range(2):
print "Play Movie %s! %s" %(func,ctime())
sleep(5)
threads = []
t1 = threading.Thread(target=music,args=(u'幸福的孩子爱唱歌',))
threads.append(t1)
t2 = threading.Thread(target=movie,args=(u'丁丁历险记',))
threads.append(t2)
if __name__ == '__main__':
for t in threads:
t.setDaemon(True)
t.start()
for t in threads:
t.join()
print "all over %s" %ctime()
setDaemon(True)将线程声明为守护线程,必须在start() 方法调用之前设置。如果不设置为守护线程则程序会被无限挂起。
join()方法,用于等待线程终止。join()的作用是,在子线程完成运行之前,这个子线程的父线程将一直被阻塞。如果不设置,当父线程执行完最后一条语句print "all over %s" %ctime()后,没有等待子线程,直接就退出了,同时子线程也一同结束。