Python多線程實(shí)現(xiàn)模擬火車站售票
發(fā)布日期：2022-02-01 12:38 | 文章來源：gibhub
本文實(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í)有所幫助，也希望大家多多支持本站。
版權(quán)聲明：本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非maisonbaluchon.cn所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學(xué)習(xí)參考，不代表本站立場，如有內(nèi)容涉嫌侵權(quán)，請聯(lián)系alex-e#qq.com處理。
相關(guān)文章
關(guān)注官方微信