from queue import Queue#先進(jìn)先出隊(duì)列
from queue import PriorityQueue#優(yōu)先級(jí)隊(duì)列
import time
#隊(duì)列：先進(jìn)先出
q = Queue()#創(chuàng)建一個(gè)空隊(duì)列，隊(duì)列大小沒有指定
#判斷隊(duì)列是是否為空
#當(dāng)一個(gè)隊(duì)列為空的時(shí)候如果再用get取則會(huì)堵塞，所以取隊(duì)列的時(shí)候一般是用到
#get_nowait()方法，這種方法在向一個(gè)空隊(duì)列取值的時(shí)候會(huì)拋一個(gè)Empty異常
#所以更常用的方法是先判斷一個(gè)隊(duì)列是否為空，如果不為空則取值
?
?
print(q.empty())
#隊(duì)列的操作：存--put() ?取--get()
q.put('page1')
q.put('page2')
q.put('page3')
?
print(q.empty())
#判斷隊(duì)列是否已經(jīng)滿了
print(q.full())
?
q1 = Queue(3)#在創(chuàng)建隊(duì)列時(shí)，指定隊(duì)列大小（表示該隊(duì)列最多能存多少個(gè)元素）
q1.put('1')
q1.put('1')
q1.put('1')
print(q1.full())
?
?
q2 = Queue(3)
q2.put('1')
q2.put('2')
q2.put('3')
value = q2.get()#遵循的原則是：先進(jìn)先出
print(value)
print(q2.full())
?
#存數(shù)據(jù)---阻塞
q3 = Queue(3)
q3.put(1)
q3.put(2)
q3.put(3)
# q3.put(4)#如果隊(duì)列已經(jīng)滿了，等著（阻塞），一直等到隊(duì)列騰出空間，然后把值存入到隊(duì)列當(dāng)中。
?
#取數(shù)據(jù)--阻塞
q4 = Queue(3)
q4.put(1)
value = q4.get()#1,此時(shí)隊(duì)列為空
print('q4:',value)
# value = q4.get()#阻塞，直到隊(duì)列當(dāng)中有新值的時(shí)候，取出，結(jié)束阻塞。
?
#非阻塞
q5 = Queue(3)
q5.put(1)
?
#1.取
print('q5.qsize:',q5.qsize())#當(dāng)前隊(duì)列當(dāng)中的元素個(gè)數(shù)
#方法1：
# while not q5.empty():
# ? ? value2 = q5.get(block=False)#block為Ture，表示阻塞，否則為非阻塞。非阻塞就是“強(qiáng)取”
# ? ? print('q5：',value2)
#方法2：
while q5.qsize()>0:
? ? value2 = q5.get(block=False)
? ? print('q5：',value2)
?
print('q5.qsize:',q5.qsize())
#存
q6 = Queue(3)
?
#方法1：
# print(q6.maxsize)#得到隊(duì)列最大容量
# i = 0
# while i<q6.maxsize:
# ? ? q6.put(i)
# ? ? i+=1
?
#方法2：
while not q6.full():
? ? q6.put(1,block=False)#非阻塞
?
?
'''------------------------------其它的屬性和方法-----------------------------'''
q7 = Queue(3)
# q7.get(block=False)
print(time.time())
try:
? ? q7.get(timeout=2)#阻塞時(shí)長(zhǎng)
except:
? ? pass
print(time.time())
?
q8 = Queue(3)
# q8.get_nowait()#強(qiáng)取
?
'''------------------------------優(yōu)先級(jí)隊(duì)列-----------------------------'''
q = PriorityQueue()
?
# 格式：q.put((數(shù)字,值))
#特點(diǎn)：數(shù)字越小，優(yōu)先級(jí)越高
q.put((1,'lori'))
q.put((-1,'Jseon'))
q.put((10,'King'))
?
i = 0
while i<q.qsize():
? ? print(q.get())

import heapq
?
class PriorityQueue(object):
? ? def __init__(self):
? ? ? ? self._queue = [] ? ? ? ?#創(chuàng)建一個(gè)空列表用于存放隊(duì)列
? ? ? ? self._index = 0 ? ? ? ?#指針用于記錄push的次序
? ??
? ? def push(self, item, priority):
? ? ? ? """隊(duì)列由（priority, index, item)形式的元祖構(gòu)成"""
? ? ? ? heapq.heappush(self._queue, (-priority, self._index, item))?
? ? ? ? self._index += 1
? ? ? ??
? ? def pop(self):
? ? ? ? return heapq.heappop(self._queue)[-1] ? ?#返回?fù)碛凶罡邇?yōu)先級(jí)的項(xiàng)
?
class Item(object):
? ? def __init__(self, name):
? ? ? ? self.name = name
?
? ? def __repr__(self):
? ? ? ? return 'Item: {!r}'.format(self.name)
?
if __name__ == '__main__':
? ? q = PriorityQueue()
? ? q.push(Item('foo'), 5)
? ? q.push(Item('bar'), 1)
? ? q.push(Item('spam'), 3)
? ? q.push(Item('grok'), 1)
? ? for i in range(4):
? ? ? ? print(q._queue)
? ? ? ? print(q.pop())

import queue
if __name__ == '__main__':
    queue = queue.PriorityQueue()
    queue.put((100, 100))
    queue.put((-12, -7))
    queue.put((7, 8))
    while not queue.empty():
        print(queue.get())