import threading #首先导入threading 模块，这是使用多线程的前提 from time import ctime,sleep
def music(func): for i in range(3): print "I was listening to" +func+ctime() sleep(2) def movie(func): for i in range(2): print "I was at the %s! %s" %(func,ctime()) sleep(5)
def eat_time(func): for i in range(5): print 'l am eatting food %s. %s' %(func,ctime()) sleep(1)
threads = [] t1 = threading.Thread(target=music,args=(u'爱情买卖',)) threads.append(t1) #创建了threads数组，创建线程t1,使用threading.Thread()方法，在这个方法中调用music方法target=music，args方法对music进行传参。 把创建好的线程t1装到threads数组中。 t2 = threading.Thread(target=movie,args=(u'阿凡达',)) threads.append(t2) t3 = threading.Thread(target=eat_time,args=(u'爆米花',)) threads.append(t3) if __name__ == '__main__': for t in threads: t.setDaemon(True) #setDaemon(True)将线程声明为守护线程，必须在start() 方法调用之前设置，如果不设置为守护线程程序会被无限挂起。子线程启动后，父线程也继续执行下去，当父线程执行完最后一条语句后，没有等待子线程，直接就退出了，同时子线程也一同结束。 t.start() #开始线程活动 print "夜深了我要睡觉了！！！！！！！！！！！！！！！！！！！！！！！！！！！！ %s" %ctime() #此句代码为主线程
运行的结果是：
I was listening to爱情买卖Wed Nov 09 22:32:16 2016 I was at the 阿凡达! Wed Nov 09 22:32:16 2016 l am eatting food 爆米花. Wed Nov 09 22:32:16 2016 夜深了我要睡觉了！！！！！！！！！！！！！！！！！！！！！ ！！！！！Wed Nov 09 22:32:16 2016 这是主线程 l am eatting food 爆米花. Wed Nov 09 22:32:17 2016 I was listening to爱情买卖Wed Nov 09 22:32:18 2016 l am eatting food 爆米花. Wed Nov 09 22:32:18 2016 l am eatting food 爆米花. Wed Nov 09 22:32:19 2016 I was listening to爱情买卖Wed Nov 09 22:32:20 2016 l am eatting food 爆米花. Wed Nov 09 22:32:20 2016 I was at the 阿凡达! Wed Nov 09 22:32:21 2016
如果我们把上面的程序结尾处添加t.jion()如下：
if __name__ == '__main__': for t in threads: t.setDaemon(True) t.start() t.join() print "夜深了我要睡觉了！！！！！！！！！！！！！！！！！！！！！！ %s" %ctime()
运行结果：
I was listening to爱情买卖Wed Nov 09 22:52:04 2016 I was at the 阿凡达! Wed Nov 09 22:52:04 2016 l am eatting food 爆米花. Wed Nov 09 22:52:04 2016 l am eatting food 爆米花. Wed Nov 09 22:52:05 2016 I was listening to爱情买卖Wed Nov 09 22:52:06 2016 l am eatting food 爆米花. Wed Nov 09 22:52:06 2016 l am eatting food 爆米花. Wed Nov 09 22:52:07 2016 I was listening to爱情买卖Wed Nov 09 22:52:08 2016 l am eatting food 爆米花. Wed Nov 09 22:52:08 2016 I was at the 阿凡达! Wed Nov 09 22:52:09 2016 夜深了我要睡觉了！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！ Wed Nov 09 22:52:09 2016
我们只对上面的程序加了个join()方法，用于等待线程终止。join（）的作用是，在子线程完成运行之前，这个子线程的父线程将一直被阻塞。
注意: join()方法的位置是在for循环外的，也就是说必须等待for循环里的两个进程都结束后，才去执行主进程。
下面是将上面的程序进行简化！
from time import sleep, ctime import threading def muisc(func): for i in range(2): print 'Start playing： %s! %s' %(func,ctime()) sleep(2) def move(func): for i in range(2): print 'Start playing： %s! %s' %(func,ctime()) sleep(5) def player(name): r = name.split('.')[1] if r == 'mp3': muisc(name) else: if r == 'mp4': move(name) else: print 'error: The format of %s is not recognized!' %r list = ['爱情买卖.mp3','阿凡达.mp4','在吃东西.pic','简单爱.mp3','星球大战.mp4'] threads = [] files = range(len(list)) #创建线程 for i in files: t = threading.Thread(target=player,args=(list[i],)) threads.append(t) if __name__ == '__main__': #启动线程 for i in files: threads[i].start() threads[i].join() #主线程 print 'end:%s' %ctime()
运行结果：
Start playing： 爱情买卖.mp3! Wed Nov 09 23:53:30 2016 Start playing： 爱情买卖.mp3! Wed Nov 09 23:53:32 2016 Start playing： 阿凡达.mp4! Wed Nov 09 23:53:34 2016 Start playing： 阿凡达.mp4! Wed Nov 09 23:53:39 2016 error: The format of pic is not recognized! Start playing： 简单爱.mp3! Wed Nov 09 23:53:44 2016 Start playing： 简单爱.mp3! Wed Nov 09 23:53:46 2016 Start playing： 星球大战.mp4! Wed Nov 09 23:53:48 2016 Start playing： 星球大战.mp4! Wed Nov 09 23:53:53 2016 end:Wed Nov 09 23:53:58 2016
下面我们来做一个超级播放器！
from time import sleep, ctime import threading def super_player(file,time): for i in range(2): print 'Start playing： %s! %s' %(file,ctime()) sleep(time) #播放的文件与播放时长 list = {'爱情买卖.mp3':3,'阿凡达.mp4':5,'我和你.mp3':4} threads = [] files = range(len(list)) #创建线程 for file,time in list.items(): t = threading.Thread(target=super_player,args=(file,time)) threads.append(t) if __name__ == '__main__': #启动线程 for i in files: threads[i].start() threads[i].join() #主线程 print 'end:%s' %ctime()
运行结果：
Start playing： 爱情买卖.mp3! Thu Nov 10 00:01:57 2016 Start playing： 爱情买卖.mp3! Thu Nov 10 00:02:00 2016 Start playing： 我和你.mp3! Thu Nov 10 00:02:03 2016 Start playing： 我和你.mp3! Thu Nov 10 00:02:07 2016 Start playing： 阿凡达.mp4! Thu Nov 10 00:02:11 2016 Start playing： 阿凡达.mp4! Thu Nov 10 00:02:16 2016 end:Thu Nov 10 00:02:21 2016
下面是创建一个自己的多线程类：
import threading from time import sleep, ctime class MyThread(threading.Thread): #创建MyThread类，用于继承threading.Thread类
def __init__(self,func,args,name=''): # __init__()使用类的初始化方法对func、args、name等参数进行初始化 threading.Thread.__init__(self) self.name=name self.func=func self.args=args def run(self): apply(self.func,self.args) #apply(func [, args [, kwargs ]]) 函数用于当函数参数已经存在于一个元组或字典中时，间接地调用函数。
args是一个包含将要提供给函数的按位置传递的参数的元组。如果省略了args，任何参数都不会被传递，kwargs是一个包含关键字参数的字典 def super_play(file,time): for i in range(2): print 'Start playing： %s! %s' %(file,ctime()) sleep(time) list = {'爱情买卖.mp3':3,'阿凡达.mp4':5} #创建线程 threads = [] files = range(len(list)) for k,v in list.items(): t = MyThread(super_play,(k,v),super_play.__name__) threads.append(t) if __name__ == '__main__': #启动线程 for i in files: threads[i].start() threads[i].join() #主线程 print 'end:%s' %ctime()
运行结果：
Start playing： 爱情买卖.mp3! Thu Nov 10 00:10:09 2016 Start playing： 爱情买卖.mp3! Thu Nov 10 00:10:12 2016 Start playing： 阿凡达.mp4! Thu Nov 10 00:10:15 2016 Start playing： 阿凡达.mp4! Thu Nov 10 00:10:20 2016 end:Thu Nov 10 00:10:25 2016