Commit b28ff3f1 authored by Denis Bilenko's avatar Denis Bilenko

fix test__queue.py

parent c1f01e96
...@@ -162,7 +162,7 @@ class TestQueue(TestCase): ...@@ -162,7 +162,7 @@ class TestQueue(TestCase):
waiting_evt = AsyncResult() waiting_evt = AsyncResult()
gevent.spawn(do_receive, q, dying_evt) gevent.spawn(do_receive, q, dying_evt)
gevent.spawn(waiter, q, waiting_evt) gevent.spawn(waiter, q, waiting_evt)
gevent.sleep(0) gevent.sleep(0.01)
q.put('hi') q.put('hi')
self.assertEquals(dying_evt.get(), 'timed out') self.assertEquals(dying_evt.get(), 'timed out')
self.assertEquals(waiting_evt.get(), 'hi') self.assertEquals(waiting_evt.get(), 'hi')
...@@ -182,7 +182,7 @@ class TestQueue(TestCase): ...@@ -182,7 +182,7 @@ class TestQueue(TestCase):
e2 = AsyncResult() e2 = AsyncResult()
gevent.spawn(do_receive, q, e1) gevent.spawn(do_receive, q, e1)
gevent.spawn(do_receive, q, e2) gevent.spawn(do_receive, q, e2)
gevent.sleep(0) gevent.sleep(0.01)
q.put('sent') q.put('sent')
self.assertEquals(e1.get(), 'timed out') self.assertEquals(e1.get(), 'timed out')
self.assertEquals(e2.get(), 'timed out') self.assertEquals(e2.get(), 'timed out')
......
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