本文實(shí)例為大家分享了Python多線(xiàn)程模擬火車(chē)站售票的具體代碼,供大家參考,具體內(nèi)容如下
Python的標(biāo)準(zhǔn)庫(kù)提供了兩個(gè)模塊:thread和threading,thread是低級(jí)模塊,threading是高級(jí)模塊,對(duì)thread進(jìn)行了封裝。
我們使用threading這個(gè)高級(jí)模塊, 模擬火車(chē)站賣(mài)票,如果不加鎖,賣(mài)出同一張票:
import threading from time import sleep, ctime N = 100 # 100張票 def Sell(name): global N while True: if N>0: sleep(0.1) #加入此句,可以讓線(xiàn)程賣(mài)出第0張票或同一張票 print("{}賣(mài)出第{}張票! ".format(name,N)) N=N-1 def main(): threads = {} for i in ( "A" ,"B" ): # 實(shí)例化每個(gè) Thread 對(duì)象,把函數(shù)和參數(shù)傳遞進(jìn)去,返回 Thread 實(shí)例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配線(xiàn)程 for i in ("A" ,"B"): threads[i].start() # 開(kāi)始執(zhí)行多線(xiàn)程 for i in ("A" ,"B"): threads[i].join() # 等待線(xiàn)程結(jié)束或超時(shí),然后再往下執(zhí)行 print("程序結(jié)束!") if __name__ == "__main__": main()
運(yùn)行效果:
我們使用鎖來(lái)避免賣(mài)出同一張票,當(dāng)多個(gè)線(xiàn)程同時(shí)執(zhí)行l(wèi)ock.acquire()時(shí),只有一個(gè)線(xiàn)程能成功地獲取鎖,然后繼續(xù)執(zhí)行代碼,其他線(xiàn)程就等待直到獲得鎖為止。用try...finally來(lái)確保鎖一定會(huì)被釋放。
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) #加入此句,可以讓線(xiàn)程賣(mài)出第0張票或同一張票 print("{}賣(mài)出第{}張票! ".format(name,N)) N=N-1 finally: # 改完了一定要釋放鎖: lock.release() def main(): threads = {} for i in ( "A" ,"B" ): # 實(shí)例化每個(gè) Thread 對(duì)象,把函數(shù)和參數(shù)傳遞進(jìn)去,返回 Thread 實(shí)例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配線(xiàn)程 for i in ("A" ,"B"): threads[i].start() # 開(kāi)始執(zhí)行多線(xiàn)程 for i in ("A" ,"B"): threads[i].join() # 等待線(xiàn)程結(jié)束或超時(shí),然后再往下執(zhí)行 print("程序結(jié)束!") if __name__ == "__main__": main()
運(yùn)行效果:
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持服務(wù)器之家。
原文鏈接:https://blog.csdn.net/HQ354974212/article/details/89603615