激情久久久_欧美视频区_成人av免费_不卡视频一二三区_欧美精品在欧美一区二区少妇_欧美一区二区三区的

腳本之家,腳本語言編程技術及教程分享平臺!
分類導航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服務器之家 - 腳本之家 - Python - Python中多線程及程序鎖淺析

Python中多線程及程序鎖淺析

2020-05-20 09:17腳本之家 Python

這篇文章主要介紹了Python中多線程及程序鎖淺析,本文用一個實例講解Python的多線程和程序鎖,需要的朋友可以參考下

Python中多線程使用到Threading模塊。Threading模塊中用到的主要的類是Thread,我們先來寫一個簡單的多線程代碼:

復制代碼 代碼如下:


# coding : uft-8
__author__ = 'Phtih0n'
import threading

 

class MyThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)

    def run(self):
        global n
        print n
        n += 1

if "__main__" == __name__:
    n = 0
    ThreadList = []
    for i in range(0, 10):
        t = MyThread()
        ThreadList.append(t)
    for t in ThreadList:
        t.start()
    for t in ThreadList:
        t.join

 

最普通的一個多線程小例子。我一筆帶過地講一講,我創建了一個繼承Thread類的子類MyThread,作為我們的線程啟動類。按照規定,重寫Thread的run方法,我們的線程啟動起來后會自動調用該方法。于是我首先創建了10個線程,并將其加入列表中。再使用一個for循環,開啟每個線程。在使用一個for循環,調用join方法等待所有線程結束才退出主線程。

這段代碼看似簡單,但實際上隱藏著一個很大的問題,只是在這里沒有體現出來。你真的以為我創建了10個線程,并按順序調用了這10個線程,每個線程為n增加了1.實際上,有可能是A線程執行了n++,再C線程執行了n++,再B線程執行n++。

這里涉及到一個“鎖”的問題,如果有多個線程同時操作一個對象,如果沒有很好地保護該對象,會造成程序結果的不可預期(比如我們在每個線程的run方法中加入一個time.sleep(1),并同時輸出線程名稱,則我們會發現,輸出會亂七八糟。因為可能我們的一個print語句只打印出一半的字符,這個線程就被暫停,執行另一個去了,所以我們看到的結果很亂),這種現象叫做“線程不安全”:

Python中多線程及程序鎖淺析

于是,Threading模塊為我們提供了一個類,Threading.Lock,鎖。我們創建一個該類對象,在線程函數執行前,“搶占”該鎖,執行完成后,“釋放”該鎖,則我們確保了每次只有一個線程占有該鎖。這時候對一個公共的對象進行操作,則不會發生線程不安全的現象了。

于是,我們把代碼更改如下:

 

復制代碼 代碼如下:


# coding : uft-8
__author__ = 'Phtih0n'
import threading, time

 

class MyThread(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)

    def run(self):
        global n, lock
        time.sleep(1)
        if lock.acquire():
            print n , self.name
            n += 1
            lock.release()

if "__main__" == __name__:
    n = 1
    ThreadList = []
    lock = threading.Lock()
    for i in range(1, 200):
        t = MyThread()
        ThreadList.append(t)
    for t in ThreadList:
        t.start()
    for t in ThreadList:
        t.join()

 

最后執行結果:

Python中多線程及程序鎖淺析

我們看到,我們先建立了一個threading.Lock類對象lock,在run方法里,我們使用lock.acquire()獲得了這個鎖。此時,其他的線程就無法再獲得該鎖了,他們就會阻塞在“if lock.acquire()”這里,直到鎖被另一個線程釋放:lock.release()。

所以,if語句中的內容就是一塊完整的代碼,不會再存在執行了一半就暫停去執行別的線程的情況。所以最后結果是整齊的。

就如同在java中,我們使用synchronized關鍵字修飾一個方法,目的一樣,讓某段代碼被一個線程執行時,不會打斷跳到另一個線程中。

這是多線程占用一個公共對象時候的情況。如果多個線程要調用多個現象,而A線程調用A鎖占用了A對象,B線程調用了B鎖占用了B對象,A線程不能調用B對象,B線程不能調用A對象,于是一直等待。這就造成了線程“死鎖”。

Threading模塊中,也有一個類,RLock,稱之為可重入鎖。該鎖對象內部維護著一個Lock和一個counter對象。counter對象記錄了acquire的次數,使得資源可以被多次require。最后,當所有RLock被release后,其他線程才能獲取資源。在同一個線程中,RLock.acquire可以被多次調用,利用該特性,可以解決部分死鎖問題。

死鎖問題很復雜,多年來人們想出了很多算法來解決它。我就不再多說,具體還是要大家參閱幫助文檔。

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 欧美国产精品久久 | 性欧美videos另类极品 | 一级大片久久 | 网站一区 | 久色亚洲| 成人毛片视频在线观看 | 91精品国产综合久久婷婷香 | 九九午夜| 久久免费视频精品 | 日韩视频一二区 | 海角在线观看91一区二区 | 久久精品亚洲一区二区 | 久久免费视屏 | 免费国产网站 | 国产高潮国产高潮久久久91 | 色吧久久| 91亚洲精品一区二区福利 | 国产成人自拍小视频 | 欧美黑大粗硬毛片视频 | 亚洲国产精久久久久久久 | 在线播放污 | 全网免费毛片 | 免费毛片随便看 | 中文字幕在线观看精品 | 精品一区二区三区免费 | 粉嫩粉嫩一区二区三区在线播放 | 久久网国产精品 | 伊人成人免费视频 | 男女一边摸一边做羞羞视频免费 | 色婷婷av一区二区三区久久 | 日韩视频在线视频 | 亚洲福利视 | 免费在线观看国产 | 欧美日韩在线播放 | 91精品久久久久久久 | 思思久而久而蕉人 | 日本一区二区免费在线播放 | 一本一道久久久a久久久精品91 | 国产流白浆高潮在线观看 | 成人毛片视频在线观看 | 本站只有精品 |