Searched refs:put_nowait (Results 1 - 11 of 11) sorted by relevance
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_queues.py | 34 q.put_nowait(0)
41 q.put_nowait(1)
53 q.put_nowait(1)
124 q.put_nowait(1)
157 loop.call_later(0.01, q.put_nowait, 1)
164 q.put_nowait(1)
248 q.put_nowait(1)
258 q.put_nowait(1)
259 q.put_nowait(2)
283 q.put_nowait(
[all...] |
| /third_party/python/Lib/asyncio/ |
| H A D | queues.py | 17 """Raised when the Queue.put_nowait() method is called on a full Queue."""
135 return self.put_nowait(item)
137 def put_nowait(self, item): member in Queue
166 # previous put_nowait call.
169 # We were woken up by put_nowait(), but can't take
|
| H A D | tasks.py | 589 done.put_nowait(None) # Queue a dummy value for _wait_for_one().
596 done.put_nowait(f)
|
| /third_party/python/Lib/test/ |
| H A D | test_queue.py | 222 q.put_nowait(1)
224 q.put_nowait(1)
238 q.put_nowait(4)
242 q.put_nowait(4)
511 q.put_nowait(3)
|
| H A D | _test_multiprocessing.py | 988 queue.put_nowait(6)
997 put_nowait = TimingWrapper(queue.put_nowait)
1005 self.assertRaises(pyqueue.Full, put_nowait, 7)
1006 self.assertTimingAlmostEqual(put_nowait.elapsed, 0)
|
| /third_party/python/Lib/ |
| H A D | queue.py | 24 'Exception raised by Queue.put(block=0)/put_nowait().'
185 def put_nowait(self, item): member in Queue
298 def put_nowait(self, item): member in _PySimpleQueue
|
| /third_party/node/deps/v8/tools/gcmole/ |
| H A D | gcmole.py | 152 output_queue.put_nowait((filename, ret, stdout, stderr))
162 output_queue.put_nowait(success)
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | queues.py | 137 def put_nowait(self, obj): member in Queue
|
| /third_party/python/Lib/logging/ |
| H A D | handlers.py | 1452 The base implementation uses put_nowait. You may want to override
1456 self.queue.put_nowait(record)
1594 The base implementation uses put_nowait. You may want to override this
1598 self.queue.put_nowait(self._sentinel)
|
| /third_party/python/Lib/concurrent/futures/ |
| H A D | process.py | 538 self.call_queue.put_nowait(None)
|
| /third_party/node/tools/ |
| H A D | test.py | 110 self.parallel_queue.put_nowait(case)
112 self.sequential_queue.put_nowait(case)
|
Completed in 18 milliseconds