python多線程編程2

如上一節,python的threading.Thread類有一個run方法,用於定義線程的功能函數,可以在自己的線程類中覆蓋該方法。而創建自己的線程實例後,通過Thread類的start方法,可以啟動該線程,交給python虛擬機進行調度,當該線程獲得執行的機會時,就會調用run方法執行線程。讓我們開始第一個例子:# encoding: UTF-8

import threading

import time

class MyThread(threading.Thread):

def run(self):

for i in range(3):

time.sleep(1)

msg = "I'm "+self.name+' @ '+str(i)

print msg

def test():

for i in range(5):

t = MyThread()

t.start()

if __name__ == '__main__':

test()

執行結果:

I'm Thread-1 @ 0

I'm Thread-2 @ 0

I'm Thread-5 @ 0

I'm Thread-3 @ 0

I'm Thread-4 @ 0

I'm Thread-3 @ 1

I'm Thread-4 @ 1

I'm Thread-5 @ 1

I'm Thread-1 @ 1

I'm Thread-2 @ 1

I'm Thread-4 @ 2

I'm Thread-5 @ 2

I'm Thread-2 @ 2

I'm Thread-1 @ 2

I'm Thread-3 @ 2

從代碼和執行結果我們可以看出,多線程程序的執行順序是不確定的。當執行到sleep語句時,線程將被阻塞(Blocked),到sleep結束後,線程進入就緒(Runnable)狀態,等待調度。而線程調度將自行選擇一個線程執行。上面的代碼中只能保證每個線程都運行完整個run函數,但是線程的啟動順序、run函數中每次循環的執行順序都不能確定。

此外需要注意的是:

1.每個線程一定會有一個名字,儘管上面的例子中沒有指定線程對象的name,但是python會自動為線程指定一個名字。

2.當線程的run()方法結束時該線程完成。

3. 無法控制線程調度程序,但可以通過別的方式來影響線程調度的方式。

上面的例子只是簡單的演示了創建了線程、主動掛起以及退出線程。下一節,將討論用互斥鎖進行線程同步。

更多技巧請《轉發 + 關注》哦!


分享到:


相關文章: