首页 > 技术文章 > Python的多线程

LegendOfBFS 2016-04-15 11:19 原文

单线程

 

任务多的时候,一件一件做,排个先后。一个任务没有完成的时候,不能开始新任务。

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()后,没有等待子线程,直接就退出了,同时子线程也一同结束。

推荐阅读