from queue import Queue

q = Queue(5) ?# 創(chuàng)建一個容量為5的隊列。如果給一個小于0的數(shù)，則隊列為無限大小。（這是官方的解釋，實際不是無限大小，而是跟內(nèi)存有關）

# 存儲數(shù)據(jù)
q.put(123) ?# 數(shù)值?
q.put('hello world!') ?# 字符串
q.put(['hello', 'world']) ?# 列表
q.put(('hello', 'world')) ?# 元組
q.put({'hello': 'world'}) ?# 字典

# 如果再試圖存儲第六個，則會發(fā)生阻塞，因為容量已設定為5
# q.put({'hello': 'python'})

print(q.get())
print(q.get())
print(q.get())
print(q.get())
print(q.get())

print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())

print(q.full())
print(q.get())
print(q.get())
print(q.full())
print(q.empty())
print(q.get())
print(q.get())
print(q.get())
print(q.empty())

from queue import Queue
import threading
import time


# 存儲值，每隔一秒存儲一個
def set_value(q):
? ? num = 0
? ? while True:
? ? ? ? q.put(num)
? ? ? ? num += 1
? ? ? ? time.sleep(1)

# 取值，不間斷地取
def get_value(q):
? ? while True:
? ? ? ? print(q.get())


if __name__ == '__main__':
? ? q = Queue(4)
? ? t1 = threading.Thread(target=set_value, args=(q, ))
? ? t2 = threading.Thread(target=get_value, args=(q, ))

? ? t1.start()
? ? t2.start()