python 多線程就這么簡單（續）

 

　　之前講了多線程的一篇博客，感覺講的意猶未盡，其實，多線程非常有意思。因為我們在使用電腦的過程中無時無刻都在多進程和多線程。我們可以接着之前的例子繼續講。請先看我的上一篇博客。

python 多線程就這么簡單

　　從上面例子中發現線程的創建是頗為麻煩的，每創建一個線程都需要創建一個tx（t1、t2、...），如果創建的線程多時候這樣極其不方便。下面對通過例子進行繼續改進：

player.py

#coding=utf-8
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 is not recognized!' list = ['愛情買賣.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() 　for i in files: 　　 threads[i].join() #主線程
    print 'end:%s' %ctime()

 

　　有趣的是我們又創建了一個player()函數，這個函數用於判斷播放文件的類型。如果是mp3格式的，我們將調用music()函數，如果是mp4格式的我們調用move()函數。哪果兩種格式都不是那么只能告訴用戶你所提供有文件我播放不了。

　　然后，我們創建了一個list的文件列表，注意為文件加上后綴名。然后我們用len(list) 來計算list列表有多少個文件，這是為了幫助我們確定循環次數。

　　接着我們通過一個for循環，把list中的文件添加到線程中數組threads[]中。接着啟動threads[]線程組，最后打印結束時間。

     split()可以將一個字符串拆分成兩部分，然后取其中的一部分。

 

>>> x = 'testing.py'
>>> s = x.split('.')[1] >>> if s=='py': print s py

 

 

 

運行結果：

Start playing： 愛情買賣.mp3! Mon Apr 21 12:48:40 2014 Start playing： 阿凡達.mp4! Mon Apr 21 12:48:40 2014 Start playing： 愛情買賣.mp3! Mon Apr 21 12:48:42 2014 Start playing： 阿凡達.mp4! Mon Apr 21 12:48:45 2014 end:Mon Apr 21 12:48:50 2014

現在向list數組中添加一個文件，程序運行時會自動為其創建一個線程。

 

繼續改進例子：

　　通過上面的程序，我們發現player()用於判斷文件擴展名，然后調用music()和move() ，其實，music()和move()完整工作是相同的，我們為什么不做一台超級播放器呢，不管什么文件都可以播放。經過改造，我的超級播放器誕生了。

super_player.py

 

#coding=utf-8
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() 　　for i in files: 　　 threads[i].join() #主線程
    print 'end:%s' %ctime()

 

　　首先創建字典list ，用於定義要播放的文件及時長（秒），通過字典的items()方法來循環的取file和time，取到的這兩個值用於創建線程。

　　接着創建super_player()函數，用於接收file和time，用於確定要播放的文件及時長。

　　最后是線程啟動運行。運行結果：

Start playing： 愛情買賣.mp3! Fri Apr 25 09:45:09 2014 Start playing： 我和你.mp3! Fri Apr 25 09:45:09 2014 Start playing： 阿凡達.mp4! Fri Apr 25 09:45:09 2014 Start playing： 愛情買賣.mp3! Fri Apr 25 09:45:12 2014 Start playing： 我和你.mp3! Fri Apr 25 09:45:13 2014 Start playing： 阿凡達.mp4! Fri Apr 25 09:45:14 2014 end:Fri Apr 25 09:45:19 2014

 

 

創建自己的多線程類

 

#coding=utf-8
import threading from time import sleep, ctime class MyThread(threading.Thread): def __init__(self,func,args,name=''): threading.Thread.__init__(self) self.name=name self.func=func self.args=args def run(self): apply(self.func,self.args) 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() 　　for i in files: 　　 threads[i].join() #主線程
    print 'end:%s' %ctime()

 

MyThread(threading.Thread)

創建MyThread類，用於繼承threading.Thread類。

 

__init__()

使用類的初始化方法對func、args、name等參數進行初始化。  

apply()

　　apply(func [, args [, kwargs ]]) 函數用於當函數參數已經存在於一個元組或字典中時，間接地調用函數。args是一個包含將要提供給函數的按位置傳遞的參數的元組。如果省略了args，任何參數都不會被傳遞，kwargs是一個包含關鍵字參數的字典。

apply() 用法：

 

#不帶參數的方法
>>> def say():
    print 'say in'

>>> apply(say)
say in

#函數只帶元組的參數
>>> def say(a,b):
    print a,b

>>> apply(say,('hello','蟲師'))
hello 蟲師

#函數帶關鍵字參數
>>> def say(a=1,b=2):
    print a,b

    
>>> def haha(**kw):
    apply(say,(),kw)

    
>>> haha(a='a',b='b')
a b

 

MyThread(super_play,(k,v),super_play.__name__)

由於MyThread類繼承threading.Thread類，所以，我們可以使用MyThread類來創建線程。

運行結果：

Start playing： 愛情買賣.mp3! Fri Apr 25 10:36:19 2014 Start playing： 阿凡達.mp4! Fri Apr 25 10:36:19 2014 Start playing： 愛情買賣.mp3! Fri Apr 25 10:36:22 2014 Start playing： 阿凡達.mp4! Fri Apr 25 10:36:24 2014 all end: Fri Apr 25 10:36:29 2014