Python多線程實現模擬火車站售票
本文實例為大傢分享瞭Python多線程模擬火車站售票的具體代碼,供大傢參考,具體內容如下
Python的標準庫提供瞭兩個模塊:thread和threading,thread是低級模塊,threading是高級模塊,對thread進行瞭封裝。
我們使用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" ): # 實例化每個 Thread 對象,把函數和參數傳遞進去,返回 Thread 實例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配線程 for i in ("A" ,"B"): threads[i].start() # 開始執行多線程 for i in ("A" ,"B"): threads[i].join() # 等待線程結束或超時,然後再往下執行 print("程序結束!") if __name__ == '__main__': main()
運行效果:
我們使用鎖來避免賣出同一張票,當多個線程同時執行lock.acquire()時,隻有一個線程能成功地獲取鎖,然後繼續執行代碼,其他線程就等待直到獲得鎖為止。用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" ): # 實例化每個 Thread 對象,把函數和參數傳遞進去,返回 Thread 實例 t = threading.Thread(target=Sell, args=( i ,)) threads[i]=t # 分配線程 for i in ("A" ,"B"): threads[i].start() # 開始執行多線程 for i in ("A" ,"B"): threads[i].join() # 等待線程結束或超時,然後再往下執行 print("程序結束!") if __name__ == '__main__': main()
運行效果:
以上就是本文的全部內容,希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。