HomeSort by relevance Sort by last modified time
    Searched full:_queue (Results 1 - 25 of 45) sorted by null

1 2

  /external/python/cpython3/Lib/asyncio/
queues.py 59 self._queue = collections.deque()
62 return self._queue.popleft()
65 self._queue.append(item)
86 if getattr(self, '_queue', None):
87 result += ' _queue={!r}'.format(list(self._queue))
98 return len(self._queue)
107 return not self._queue
228 self._queue = []
231 heappush(self._queue, item
    [all...]
  /external/icu/android_icu4j/src/main/java/android/icu/impl/locale/
LocaleObjectCache.java 21 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in class:LocaleObjectCache
47 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue);
66 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) {
  /external/icu/icu4j/eclipse-build/plugins.template/com.ibm.icu.base/src/com/ibm/icu/impl/locale/
LocaleObjectCache.java 17 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in class:LocaleObjectCache
43 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue);
62 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) {
  /external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/
LocaleObjectCache.java 17 private ReferenceQueue<V> _queue = new ReferenceQueue<V>(); field in class:LocaleObjectCache
43 CacheEntry<K, V> newEntry = new CacheEntry<K, V>(key, newVal, _queue);
62 while ((entry = (CacheEntry<K, V>)_queue.poll()) != null) {
  /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/
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
130 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
133 events = self._queue[:]
  /external/python/cpython2/Lib/
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
130 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
133 events = self._queue[:]
  /prebuilts/gdb/darwin-x86/lib/python2.7/
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
130 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
133 events = self._queue[:]
  /prebuilts/gdb/linux-x86/lib/python2.7/
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
130 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
133 events = self._queue[:]
  /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/
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
130 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
133 events = self._queue[:]
  /prebuilts/python/linux-x86/2.7.5/lib/python2.7/
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
130 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
133 events = self._queue[:]
  /external/python/cpython3/Lib/
sched.py 63 self._queue = []
79 heapq.heappush(self._queue, event)
99 self._queue.remove(event)
100 heapq.heapify(self._queue)
105 return not self._queue
134 q = self._queue
165 # Use heapq to sort the queue rather than using 'sorted(self._queue)'.
169 events = self._queue[:]
  /external/libmojo/third_party/jinja2/
utils.py 304 self._queue = deque()
309 self._popleft = self._queue.popleft
310 self._pop = self._queue.pop
311 self._remove = self._queue.remove
313 self._append = self._queue.append
319 '_queue': self._queue
333 rv._queue = deque(self._queue)
362 self._queue.clear(
    [all...]
  /external/libxcam/xcore/
image_processor.cpp 104 _queue.push (result);
109 _queue.pause_pop ();
116 ResultQueue _queue; member in class:XCam::X3aResultsProcessThread
124 result = _queue.pop (-1);
129 while ((result = _queue.pop (0)).ptr ()) {
  /external/tensorflow/tensorflow/python/summary/writer/
event_file_writer.py 150 self._queue = queue
159 event = self._queue.get()
161 self._queue.task_done()
172 self._queue.task_done()
  /external/autotest/site_utils/lxc/container_pool/
async_listener.py 42 self._queue = Queue.Queue()
131 return self._queue.get(block=timeout>0, timeout=timeout)
145 self._queue.put(self._socket.accept())
  /external/skia/tools/skpbench/
skpbench.py 99 self._queue = queue
106 self._queue.put(Message(Message.READLINE, line.decode('utf-8').rstrip()))
107 self._queue.put(Message(Message.EXIT))
159 self._queue = Queue()
187 self._monitor = SubprocessMonitor(self._queue, self._proc)
191 message = self._queue.get()
217 Timer(1, lambda: self._queue.put(Message(Message.POLL_HARDWARE)))
  /external/skqp/tools/skpbench/
skpbench.py 99 self._queue = queue
106 self._queue.put(Message(Message.READLINE, line.decode('utf-8').rstrip()))
107 self._queue.put(Message(Message.EXIT))
159 self._queue = Queue()
187 self._monitor = SubprocessMonitor(self._queue, self._proc)
191 message = self._queue.get()
217 Timer(1, lambda: self._queue.put(Message(Message.POLL_HARDWARE)))
  /external/dhcpcd-6.8.2/
configure 707 cat <<EOF >_queue.c
716 if $XCC _queue.c -o _queue 2>&3; then
723 rm -f _queue.c _queue
728 cat <<EOF >_queue.c
737 if $XCC _queue.c -o _queue 2>&3; then
744 rm -f _queue.c _queue
    [all...]
  /external/mesa3d/src/gallium/state_trackers/clover/core/
event.cpp 121 _queue(q), _command(command), _fence(NULL) {
153 return &_queue();
  /external/blktrace/doc/
blktrace.tex     [all...]
  /external/mesa3d/src/intel/vulkan/
anv_wsi.c 349 VkQueue _queue,
352 ANV_FROM_HANDLE(anv_queue, queue, _queue);
377 anv_QueueSubmit(_queue, 0, NULL, swapchain->fences[0]);
  /external/mesa3d/src/amd/vulkan/
radv_wsi.c 342 VkQueue _queue,
345 RADV_FROM_HANDLE(radv_queue, queue, _queue);
  /external/syslinux/gpxe/src/drivers/net/ath5k/
ath5k.h 120 #define AR5K_REG_READ_Q(ah, _reg, _queue) \
121 (ath5k_hw_reg_read(ah, _reg) & (1 << _queue)) \
123 #define AR5K_REG_WRITE_Q(ah, _reg, _queue) \
124 ath5k_hw_reg_write(ah, (1 << _queue), _reg)
126 #define AR5K_Q_ENABLE_BITS(_reg, _queue) do { \
127 _reg |= 1 << _queue; \
130 #define AR5K_Q_DISABLE_BITS(_reg, _queue) do { \
131 _reg &= ~(1 << _queue); \
    [all...]
  /external/tensorflow/tensorflow/python/training/
queue_runner_impl.py 135 self._queue = queue
152 self._close_op = self._queue.close()
156 self._cancel_op = self._queue.close(cancel_pending_enqueues=True)
172 self._queue = g.as_graph_element(
191 return self._queue
231 return self._queue.name
  /external/scapy/scapy/
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()

Completed in 2621 milliseconds

1 2