Commit bc38d5be authored by damnever's avatar damnever Committed by Jason Madden

fix bug in PriorityQueue._init

parent b5505987
......@@ -375,6 +375,7 @@ class PriorityQueue(Queue):
def _init(self, maxsize, items=None):
if items:
self.queue = list(items)
heapq.heapify(self.queue)
else:
self.queue = []
......
......@@ -237,6 +237,12 @@ class LifoQueueTest(BaseQueueTest):
class PriorityQueueTest(BaseQueueTest):
type2test = Queue.PriorityQueue
def test__init(self):
item1 = (2, 'b')
item2 = (1, 'a')
q = self.type2test(items=[item1, item2])
self.assertTupleEqual(item2, q.get_nowait())
self.assertTupleEqual(item1, q.get_nowait())
# A Queue subclass that can provoke failure at a moment's notice :)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment