本文實(shí)例為大家分享了Python多線程模擬火車站售票的具體代碼,供大家參考,具體內(nèi)容如下
Python的標(biāo)準(zhǔn)庫提供了兩個模塊:thread和threading,thread是低級模塊,threading是高級模塊,對thread進(jìn)行了封裝。
我們使用threading這個高級模塊, 模擬火車站賣票,如果不加鎖,賣出同一張票:
import threading from time import sleep, ctime N = 100 # 100張票 def Sell(name): global N while True: if N>0: sleep(0.1) #加入此句,可以讓線程賣出第0張票或同一張票 print("{}賣出第{}張票!\n".format(name,N)) N=N-1 def main(): threads = {} for i in ( "A" ,"B" ): # 實(shí)例化每個 Thread 對象,把函數(shù)和參數(shù)傳遞進(jìn)去,返回 Thread 實(shí)例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配線程 for i in ("A" ,"B"): threads[i].start() # 開始執(zhí)行多線程 for i in ("A" ,"B"): threads[i].join() # 等待線程結(jié)束或超時,然后再往下執(zhí)行 print("程序結(jié)束!") if __name__ == '__main__': main()
運(yùn)行效果:
我們使用鎖來避免賣出同一張票,當(dāng)多個線程同時執(zhí)行l(wèi)ock.acquire()時,只有一個線程能成功地獲取鎖,然后繼續(xù)執(zhí)行代碼,其他線程就等待直到獲得鎖為止。用try...finally來確保鎖一定會被釋放。
import threading from time import sleep, ctime N = 100 # 100張票 lock = threading.Lock() def Sell(name): global N while True: lock.acquire() try: if N>0: sleep(0.1) #加入此句,可以讓線程賣出第0張票或同一張票 print("{}賣出第{}張票!\n".format(name,N)) N=N-1 finally: # 改完了一定要釋放鎖: lock.release() def main(): threads = {} for i in ( "A" ,"B" ): # 實(shí)例化每個 Thread 對象,把函數(shù)和參數(shù)傳遞進(jìn)去,返回 Thread 實(shí)例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配線程 for i in ("A" ,"B"): threads[i].start() # 開始執(zhí)行多線程 for i in ("A" ,"B"): threads[i].join() # 等待線程結(jié)束或超時,然后再往下執(zhí)行 print("程序結(jié)束!") if __name__ == '__main__': main()
運(yùn)行效果:
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
標(biāo)簽:安慶 銀川 湘西 呼倫貝爾 呼倫貝爾 葫蘆島 三亞 烏魯木齊
巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《Python多線程實(shí)現(xiàn)模擬火車站售票》,本文關(guān)鍵詞 Python,多,線程,實(shí)現(xiàn),模擬,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。