Searched refs:get_nowait (Results 1 - 12 of 12) sorted by relevance
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_queues.py | 48 q.get_nowait()
165 self.assertEqual(1, q.get_nowait())
169 self.assertRaises(asyncio.QueueEmpty, q.get_nowait)
239 loop.call_later(0.01, q.get_nowait)
249 self.assertEqual(1, q.get_nowait())
304 value1 = q.get_nowait()
315 value2 = q.get_nowait()
364 self.assertEqual(q.get_nowait(), 'a')
366 self.assertEqual(q.get_nowait(), 'b')
387 queue.get_nowait()
[all...] |
| /third_party/python/Lib/asyncio/ |
| H A D | queues.py | 12 """Raised when Queue.get_nowait() is called on an empty Queue."""
128 # previous get_nowait call.
131 # We were woken up by get_nowait(), but can't take
173 return self.get_nowait()
175 def get_nowait(self): member in Queue
|
| /third_party/python/Lib/ |
| H A D | queue.py | 20 'Exception raised by Queue.get(block=0)/get_nowait().'
193 def get_nowait(self): member in Queue
306 def get_nowait(self): member in _PySimpleQueue
|
| /third_party/python/Lib/concurrent/futures/ |
| H A D | thread.py | 210 work_item = self._work_queue.get_nowait()
224 work_item = self._work_queue.get_nowait()
|
| H A D | process.py | 522 self.work_ids_queue.get_nowait()
|
| /third_party/python/Lib/test/ |
| H A D | test_queue.py | 227 q.get_nowait()
229 q.get_nowait()
519 self.assertEqual(q.get_nowait(), 2)
535 q.get_nowait()
|
| H A D | test_logging.py | 3672 self.assertRaises(queue.Empty, self.queue.get_nowait)
3674 self.assertRaises(queue.Empty, self.queue.get_nowait)
3677 data = self.queue.get_nowait()
3691 log_record = self.queue.get_nowait()
3821 yield log_queue.get_nowait()
|
| H A D | _test_multiprocessing.py | 1061 self.assertEqual(queue.get_nowait(), 5)
1066 get_nowait = TimingWrapper(queue.get_nowait)
1074 self.assertRaises(pyqueue.Empty, get_nowait)
1075 self.assertTimingAlmostEqual(get_nowait.elapsed, 0)
|
| H A D | test_concurrent_futures.py | 277 output.append(self.log_queue.get_nowait().getMessage())
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | queues.py | 134 def get_nowait(self): member in Queue
|
| /third_party/node/deps/v8/tools/gcmole/ |
| H A D | gcmole.py | 149 filename = input_queue.get_nowait()
|
| /third_party/node/tools/ |
| H A D | test.py | 185 test = self.parallel_queue.get_nowait()
190 test = self.sequential_queue.get_nowait()
|
Completed in 32 milliseconds