Python線程專題9:線程終止與掛起、實(shí)用工具函數(shù)

dunizb 發(fā)布于2019-07-30 17:47 / 1943人閱讀

摘要：上一篇文章線程專題使用鎖的注意事項(xiàng)下一篇文章線程專題多線程按順序執(zhí)行線程沒(méi)有任何方法可用于強(qiáng)制終止或掛起。實(shí)用工具函數(shù)函數(shù)名解釋返回當(dāng)前活動(dòng)的對(duì)象數(shù)量。

上一篇文章：Python線程專題8:使用鎖的注意事項(xiàng)
下一篇文章：Python線程專題10:queue、多線程按順序執(zhí)行

線程沒(méi)有任何方法可用于強(qiáng)制終止或掛起。這是設(shè)計(jì)上的原因，因?yàn)榫帉?xiě)線程程序本身十分復(fù)雜。例如：如果某個(gè)線程已經(jīng)獲取了鎖，在它能夠釋放鎖之前強(qiáng)制終止或掛起它，將導(dǎo)致整個(gè)應(yīng)用程序出現(xiàn)死鎖。此外，終止時(shí)一般不能簡(jiǎn)單的【釋放所有的鎖】，因?yàn)閺?fù)雜的線程同步經(jīng)常涉及鎖定和清楚鎖定操作，而這些操作在執(zhí)行時(shí)的次序要十分精確。

如果要為終止或掛起提供服務(wù)，需要自己構(gòu)建這些功能。一般的做法是在循環(huán)中運(yùn)行線程，這個(gè)循環(huán)的作用是定期檢查線程的狀態(tài)以決定它是否應(yīng)該終止。例如：

from threading import  Thread,Lock
class StoppableThread(Thread):
    def __init__(self):
        Thread.__init__(self)
        self._terminate=False
        self._suspend_lock=Lock()

    def terminate(self):
        self._terminate=True

    def suspend(self):
        self._suspend_lock.acquire()

    def resume(self):
        self._suspend_lock.release()

    def run(self):
        while True:
            if self._terminate:
                break
            self._suspend_lock.acquire()
            self._suspend_lock.release()
            ...

要記住，要讓這種方法可靠的工作，線程應(yīng)該千萬(wàn)小心不要執(zhí)行任何類型的阻塞I/O操作。例如，如果線程阻塞等待數(shù)據(jù)到達(dá)，那么它會(huì)直到該操作被喚醒時(shí)才會(huì)終止。因此，你需要在實(shí)際中使用超時(shí)、非阻塞I/O和其它高級(jí)功能，從而確保終止檢查執(zhí)行的頻率足夠。

實(shí)用工具函數(shù)

函數(shù)名	解釋
active_count()	返回當(dāng)前活動(dòng)的Thread對(duì)象數(shù)量。
current_thread()	返回該函數(shù)調(diào)用者所在的線程的Thread對(duì)象。
enumerate()	列出當(dāng)前所有活動(dòng)的Thread對(duì)象
local()	返回local對(duì)象，用于保存線程本地的數(shù)據(jù)。應(yīng)該保證此對(duì)象在每個(gè)線程中是唯一的。
setprofile(func)	設(shè)置一個(gè)配置文件函數(shù)，用于已創(chuàng)建的所有線程。func在每個(gè)線程開(kāi)始運(yùn)行之前被傳遞給sys.setprofile()函數(shù)。
settrace(func)	設(shè)置一個(gè)跟蹤函數(shù)，用于已創(chuàng)建的所有線程。func在每個(gè)線程開(kāi)始運(yùn)行之前被傳遞給sys.settrace()函數(shù)。
stack_size(size)	返回創(chuàng)建新線程時(shí)使用的棧大小。可選的整數(shù)參數(shù)size表示創(chuàng)建新線程時(shí)使用的棧大小。size的值可以是32768（32kb）或更大，而且是4096（4kb）的倍數(shù)，這樣可移植性更好。如果系統(tǒng)上不支持此操作，將引發(fā)ThreadError異常。