import queue
q = queue.Queue(5) #可以傳入?yún)?shù)指定隊(duì)列大小
queue.Queue()# 不傳或者給0或者<0的數(shù)字則創(chuàng)建一個(gè)無限長度的隊(duì)列

import queue

q = queue.Queue(5)

print("學(xué)委粉絲隊(duì)列：", q)
print("空隊(duì)，學(xué)委粉絲隊(duì)列大小：", q.qsize())
print("空隊(duì)列？", q.empty())
for i in range(5):
? ? q.put(i)

print("隊(duì)列滿了？", q.full())
print("排滿了，學(xué)委粉絲隊(duì)列大?。?, q.qsize())

while not q.empty():
? ? print("粉絲 %s 出隊(duì)點(diǎn)贊！" % q.get())
print("最后，學(xué)委粉絲隊(duì)列大?。?, q.qsize())

amount = 100
def transfer(money):
? ? global amount
? ? for i in range(100000):
? ? ? ? amount += money

import queue
import threading

xuewei_fans_q = queue.Queue()


def transfer(money):
? ? for i in range(100000):
? ? ? ? xuewei_fans_q.put(money)
? ? ? ? xuewei_fans_q.get()


# 創(chuàng)建4個(gè)任務(wù)重復(fù)給學(xué)委加關(guān)注/脫粉（還是希望各位編程的明日之星跟著學(xué)習(xí)，共同進(jìn)步?。?
t_group = []
for i in range(10):
? ? t = threading.Thread(target=lambda: transfer(-1))
? ? t_group.append(t)
? ? t.start()
? ? t = threading.Thread(target=lambda: transfer(1))
? ? t_group.append(t)
? ? t.start()
? ? t = threading.Thread(target=lambda: transfer(-1))
? ? t_group.append(t)
? ? t.start()
? ? t = threading.Thread(target=lambda: transfer(1))
? ? t_group.append(t)
? ? t.start()

for t in t_group:
? ? t.join()
print("-" * 16)
print("活躍線程數(shù):", threading.active_count())
print("活躍線程:", threading.current_thread().name)
#反復(fù)對隊(duì)列進(jìn)行添加數(shù)據(jù)，移除數(shù)據(jù)，隊(duì)列最后清零了
print("學(xué)委粉絲隊(duì)列:", xuewei_fans_q.qsize())