| /external/python/cpython3/Lib/asyncio/ |
| D | queues.py | 55 self._queue = collections.deque()
58 return self._queue.popleft()
61 self._queue.append(item)
96 return len(self._queue)
105 return not self._queue
233 self._queue = []
236 heappush(self._queue, item)
239 return heappop(self._queue)
246 self._queue = []
249 self._queue.append(item)
[all …]
|
| /external/python/cpython2/Lib/ |
| D | sched.py | 42 self._queue = []
54 heapq.heappush(self._queue, event)
73 self._queue.remove(event)
74 heapq.heapify(self._queue)
78 return not self._queue
103 q = self._queue
133 events = self._queue[:]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 181 private val _queue = atomic<Any?>(null) constant
195 return when (val queue = _queue.value) {
205 val queue = _queue.value
293 _queue.loop { queue -> in enqueueImpl()
296 null -> if (_queue.compareAndSet(null, task)) return true in enqueueImpl()
301 Queue.ADD_FROZEN -> _queue.compareAndSet(queue, queue.next()) in enqueueImpl()
311 if (_queue.compareAndSet(queue, newQueue)) return true in enqueueImpl()
320 _queue.loop { queue -> in dequeue()
326 _queue.compareAndSet(queue, queue.next()) in dequeue()
330 else -> if (_queue.compareAndSet(queue, null)) return queue as Runnable in dequeue()
[all …]
|
| /external/python/cpython3/Lib/ |
| D | sched.py | 60 self._queue = []
76 heapq.heappush(self._queue, event)
96 self._queue.remove(event)
97 heapq.heapify(self._queue)
102 return not self._queue
131 q = self._queue
166 events = self._queue[:]
|
| D | queue.py | 9 from _queue import SimpleQueue
17 from _queue import Empty
269 self._queue = deque()
278 self._queue.append(item)
296 return self._queue.popleft()
316 return len(self._queue) == 0
320 return len(self._queue)
|
| /external/python/jinja/src/jinja2/ |
| D | utils.py | 337 self._queue = deque()
342 self._popleft = self._queue.popleft
343 self._pop = self._queue.pop
344 self._remove = self._queue.remove
346 self._append = self._queue.append
352 "_queue": self._queue,
366 rv._queue.extend(self._queue)
391 self._queue.clear()
415 if self._queue[-1] != key:
459 result = [(key, self._mapping[key]) for key in list(self._queue)]
[all …]
|
| /external/tensorflow/tensorflow/python/summary/writer/ |
| D | event_file_writer.py | 195 self._queue = queue
209 event = self._queue.get()
232 self._queue.close()
245 self._queue = collections.deque()
265 while not self._queue:
267 item = self._queue.popleft()
289 while len(self._queue) == self._maxsize:
293 self._queue.append(item)
|
| /external/libchrome/third_party/jinja2/ |
| D | utils.py | 316 self._queue = deque()
321 self._popleft = self._queue.popleft
322 self._pop = self._queue.pop
323 self._remove = self._queue.remove
325 self._append = self._queue.append
331 '_queue': self._queue
345 rv._queue = deque(self._queue)
374 self._queue.clear()
401 if self._queue[-1] != key:
446 result = [(key, self._mapping[key]) for key in list(self._queue)]
[all …]
|
| /external/python/jinja/tests/ |
| D | test_utils.py | 53 assert copy._queue == cache._queue
61 assert copy._queue == cache._queue
63 assert copy._queue != cache._queue
|
| /external/tensorflow/tensorflow/python/training/ |
| D | queue_runner_impl.py | 140 self._queue = queue
157 self._close_op = self._queue.close()
161 self._cancel_op = self._queue.close(cancel_pending_enqueues=True)
177 self._queue = g.as_graph_element(
196 return self._queue
236 return self._queue.name
|
| /external/icu/android_icu4j/src/main/java/android/icu/impl/locale/ |
| D | LocaleObjectCache.java | 21 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
47 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
66 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
|
| /external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/ |
| D | LocaleObjectCache.java | 17 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in LocaleObjectCache
43 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue); in get()
62 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) { in cleanStaleEntries()
|
| /external/skqp/tools/skpbench/ |
| D | skpbench.py | 112 self._queue = queue
119 self._queue.put(Message(Message.READLINE, line.decode('utf-8').rstrip()))
120 self._queue.put(Message(Message.EXIT))
186 self._queue = Queue()
214 self._monitor = SubprocessMonitor(self._queue, self._proc)
218 message = self._queue.get()
244 Timer(1, lambda: self._queue.put(Message(Message.POLL_HARDWARE)))
|
| /external/skia/tools/skpbench/ |
| D | skpbench.py | 128 self._queue = queue
135 self._queue.put(Message(Message.READLINE, line.decode('utf-8').rstrip()))
136 self._queue.put(Message(Message.EXIT))
212 self._queue = Queue()
240 self._monitor = SubprocessMonitor(self._queue, self._proc)
244 message = self._queue.get()
270 Timer(1, lambda: self._queue.put(Message(Message.POLL_HARDWARE)))
|
| /external/tensorflow/tensorflow/python/distribute/coordinator/ |
| D | cluster_coordinator.py | 455 self._queue = queue.Queue(maxsize=_CLOSURE_QUEUE_MAX_SIZE)
486 closure = self._queue.get(block=False)
527 self._queue_free_slot_condition.wait_for(lambda: not self._queue.full())
528 self._queue.put(closure, block=False)
535 while self._queue.empty() and self._should_process_closures:
540 closure = self._queue.get(block=False)
553 if self._queue.empty() and self._inflight_closure_count == 0:
564 self._queue_free_slot_condition.wait_for(lambda: not self._queue.full())
565 self._queue.put(closure, block=False)
585 (not self._queue.empty() or self._inflight_closure_count > 0)):
[all …]
|
| /external/OpenCL-CTS/test_conformance/non_uniform_work_group/ |
| D | TestNonUniformWorkGroup.h | 98 const cl_command_queue _queue; variable
128 : _device (device), _context (context), _queue (queue), _failCounter (0), _overallCounter (0) {} in SubTestExecutor()
145 const cl_command_queue _queue; variable
|
| D | TestNonUniformWorkGroup.cpp | 251 : _device(device), _context(context), _queue(queue), _dims(dims) in TestNonUniformWorkGroup()
756 err = clEnqueueNDRangeKernel(_queue, _testKernel, _dims, globalWorkOffsetPtr, _globalSize, in runKernel()
761 err = clFinish(_queue); in runKernel()
764 …err = clEnqueueReadBuffer(_queue, globalAtomicTestVariable, CL_TRUE, 0, sizeof(unsigned int), &_gl… in runKernel()
772 …err = clEnqueueReadBuffer(_queue, resultsRegionArray, CL_TRUE, 0, _resultsRegionArray.size() * siz… in runKernel()
775 …err = clEnqueueReadBuffer(_queue, errorArray, CL_TRUE, 0, _err.errorArrayCounterSize(), _err.error… in runKernel()
799 TestNonUniformWorkGroup test(_device, _context, _queue, dims, globalSize, in runTestNonUniformWorkGroup()
|
| /external/mesa3d/src/gallium/frontends/lavapipe/ |
| D | lvp_wsi.c | 226 VkQueue _queue, in lvp_QueuePresentKHR() argument
229 LVP_FROM_HANDLE(lvp_queue, queue, _queue); in lvp_QueuePresentKHR()
232 _queue, 0, in lvp_QueuePresentKHR()
|
| /external/mesa3d/src/freedreno/vulkan/ |
| D | tu_wsi.c | 246 tu_QueuePresentKHR(VkQueue _queue, const VkPresentInfoKHR *pPresentInfo) in tu_QueuePresentKHR() argument
248 TU_FROM_HANDLE(tu_queue, queue, _queue); in tu_QueuePresentKHR()
251 tu_device_to_handle(queue->device), _queue, queue->queue_family_index, in tu_QueuePresentKHR()
|
| D | tu_kgsl.c | 326 tu_QueueSubmit(VkQueue _queue, in tu_QueueSubmit() argument
331 TU_FROM_HANDLE(tu_queue, queue, _queue); in tu_QueueSubmit()
619 tu_QueueSignalReleaseImageANDROID(VkQueue _queue, in tu_QueueSignalReleaseImageANDROID() argument
625 TU_FROM_HANDLE(tu_queue, queue, _queue); in tu_QueueSignalReleaseImageANDROID()
|
| /external/mesa3d/src/broadcom/vulkan/ |
| D | v3dv_wsi.c | 266 VkQueue _queue, in v3dv_QueuePresentKHR() argument
269 V3DV_FROM_HANDLE(v3dv_queue, queue, _queue); in v3dv_QueuePresentKHR()
275 _queue, 0, in v3dv_QueuePresentKHR()
|
| /external/mesa3d/src/amd/vulkan/ |
| D | radv_wsi.c | 303 VkQueue _queue, in radv_QueuePresentKHR() argument
306 RADV_FROM_HANDLE(radv_queue, queue, _queue); in radv_QueuePresentKHR()
309 _queue, in radv_QueuePresentKHR()
|
| /external/mesa3d/src/intel/vulkan/ |
| D | anv_wsi.c | 288 VkQueue _queue, in anv_QueuePresentKHR() argument
291 ANV_FROM_HANDLE(anv_queue, queue, _queue); in anv_QueuePresentKHR()
343 _queue, 0, in anv_QueuePresentKHR()
|
| /external/scapy/scapy/ |
| D | pipetool.py | 370 self._queue = collections.deque()
374 return len(self._queue) > 0
376 self._queue.append((msg,False))
379 self._queue.append((msg,True))
387 msg,high = self._queue.popleft()
|
| /external/mesa3d/src/gallium/frontends/clover/core/ |
| D | event.cpp | 130 _queue(q), _command(command), _fence(NULL) {
162 return &_queue(); in queue()
|