本文實例為大家分享了Python多線程模擬火車站售票的具體代碼,供大家參考,具體內(nèi)容如下
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 對象,把函數(shù)和參數(shù)傳遞進去,返回 Thread 實例
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() # 等待線程結束或超時,然后再往下執(zhí)行
print("程序結束!")
if __name__ == '__main__':
main()
運行效果:
我們使用鎖來避免賣出同一張票,當多個線程同時執(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" ):
# 實例化每個 Thread 對象,把函數(shù)和參數(shù)傳遞進去,返回 Thread 實例
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() # 等待線程結束或超時,然后再往下執(zhí)行
print("程序結束!")
if __name__ == '__main__':
main()
運行效果:
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
您可能感興趣的文章:- 教你用python實現(xiàn)12306余票查詢
- Python自動化xpath實現(xiàn)自動搶票搶貨
- 春節(jié)到了 教你使用python來搶票回家
- 用Python搶火車票的簡單小程序?qū)崿F(xiàn)解析
- 為了順利買到演唱會的票用Python制作了自動搶票的腳本