| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/hotspot/share/gc/g1/ |
| H A D | g1ParScanThreadState.inline.hpp | 37 _task_queue->push(task); in push_on_queue()
41 return !_task_queue->overflow_empty() || in needs_partial_trimming()
42 (_task_queue->size() > _stack_trim_upper_threshold); in needs_partial_trimming()
52 assert(_task_queue->overflow_empty(), "invariant"); in trim_queue_partially()
53 assert(_task_queue->size() <= _stack_trim_lower_threshold, "invariant"); in trim_queue_partially()
59 assert(_task_queue->overflow_empty(), "invariant"); in trim_queue()
60 assert(_task_queue->taskqueue_empty(), "invariant"); in trim_queue()
|
| H A D | g1ServiceThread.cpp | 47 _task_queue() { in G1ServiceThread()
83 _task_queue.add_ordered(task); in schedule()
96 assert(!_task_queue.is_empty(), "Should not be called for empty list"); in time_to_next_task_ms()
98 jlong time_diff = _task_queue.peek()->time() - os::elapsed_counter(); in time_to_next_task_ms()
120 if (_task_queue.is_empty()) { in sleep_before_next_cycle()
135 if (_task_queue.is_empty() || time_to_next_task_ms() != 0) { in pop_due_task()
139 return _task_queue.pop(); in pop_due_task()
|
| H A D | g1ParScanThreadState.cpp | 60 _task_queue(g1h->task_queue(worker_id)), in G1ParScanThreadState()
303 while (_task_queue->pop_overflow(task)) { in trim_queue_to_threshold()
304 if (!_task_queue->try_push_to_taskqueue(task)) { in trim_queue_to_threshold()
308 while (_task_queue->pop_local(task, threshold)) { in trim_queue_to_threshold()
311 } while (!_task_queue->overflow_empty()); in trim_queue_to_threshold()
|
| H A D | g1ParScanThreadState.hpp | 50 G1ScannerTasksQueue* _task_queue; member in G1ParScanThreadState
123 bool queue_is_empty() const { return _task_queue->is_empty(); } in queue_is_empty()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/hotspot/share/gc/g1/ |
| H A D | g1ParScanThreadState.inline.hpp | 38 _task_queue->push(task); in push_on_queue()
42 return !_task_queue->overflow_empty() || in needs_partial_trimming()
43 (_task_queue->size() > _stack_trim_upper_threshold); in needs_partial_trimming()
53 assert(_task_queue->overflow_empty(), "invariant"); in trim_queue_partially()
54 assert(_task_queue->size() <= _stack_trim_lower_threshold, "invariant"); in trim_queue_partially()
60 assert(_task_queue->overflow_empty(), "invariant"); in trim_queue()
61 assert(_task_queue->taskqueue_empty(), "invariant"); in trim_queue()
|
| H A D | g1ServiceThread.cpp | 47 _task_queue() { in G1ServiceThread()
83 _task_queue.add_ordered(task); in schedule()
96 assert(!_task_queue.is_empty(), "Should not be called for empty list"); in time_to_next_task_ms()
98 jlong time_diff = _task_queue.peek()->time() - os::elapsed_counter(); in time_to_next_task_ms()
120 if (_task_queue.is_empty()) { in sleep_before_next_cycle()
135 if (_task_queue.is_empty() || time_to_next_task_ms() != 0) { in pop_due_task()
139 return _task_queue.pop(); in pop_due_task()
|
| H A D | g1ParScanThreadState.cpp | 60 _task_queue(g1h->task_queue(worker_id)), in G1ParScanThreadState()
297 while (_task_queue->pop_overflow(task)) { in trim_queue_to_threshold()
298 if (!_task_queue->try_push_to_taskqueue(task)) { in trim_queue_to_threshold()
302 while (_task_queue->pop_local(task, threshold)) { in trim_queue_to_threshold()
305 } while (!_task_queue->overflow_empty()); in trim_queue_to_threshold()
|
| H A D | g1ParScanThreadState.hpp | 50 G1ScannerTasksQueue* _task_queue; member in G1ParScanThreadState
121 bool queue_is_empty() const { return _task_queue->is_empty(); } in queue_is_empty()
|
| /dports/lang/micropython/micropython-1.17/extmod/uasyncio/ |
| H A D | core.py | 44 _task_queue.push_sorted(cur_task, self.state)
118 _task_queue.push_head(sm[0])
122 _task_queue.push_head(sm[1])
145 _task_queue.push_head(t)
159 t = _task_queue.peek()
170 t = _task_queue.pop_head()
201 _task_queue.push_head(t.state.pop_head())
209 _task_queue.push_head(t)
254 _task_queue.push_head(_stop_task)
286 global _task_queue, _io_queue
[all …]
|
| H A D | task.py | 169 core._task_queue.push_head(self)
172 core._task_queue.remove(self)
173 core._task_queue.push_head(self)
|
| H A D | lock.py | 26 core._task_queue.push_head(self.state)
|
| H A D | event.py | 20 core._task_queue.push_head(self.waiting.pop_head())
|
| /dports/devel/py-PyUtilib/PyUtilib-6.0.0/pyutilib/pyro/ |
| H A D | dispatcher.py | 58 self._task_queue = defaultdict(Queue.Queue)
100 self._task_queue[type].put(task)
112 task_queue = self._task_queue[task_type]
149 _clear_queue_threadsafe(self._task_queue[type])
162 self._task_queue = defaultdict(Queue.Queue)
170 _clear_queue_threadsafe(self._task_queue[type])
179 self._task_queue = defaultdict(Queue.Queue)
239 task_list.append(self._task_queue[type].get(block=block,
244 while self._task_queue[type].qsize():
246 task_list.append(self._task_queue[type].get(
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/hotspot/share/gc/g1/ |
| H A D | g1ParScanThreadState.inline.hpp | 76 _task_queue->push(task); in push_on_queue()
152 return !_task_queue->overflow_empty() || in needs_partial_trimming()
153 (_task_queue->size() > _stack_trim_upper_threshold); in needs_partial_trimming()
157 return _task_queue->overflow_empty() && in is_partially_trimmed()
158 (_task_queue->size() <= _stack_trim_lower_threshold); in is_partially_trimmed()
164 while (_task_queue->pop_overflow(task)) { in trim_queue_to_threshold()
165 if (!_task_queue->try_push_to_taskqueue(task)) { in trim_queue_to_threshold()
170 while (_task_queue->pop_local(task, threshold)) { in trim_queue_to_threshold()
|
| H A D | g1ParScanThreadState.hpp | 49 G1ScannerTasksQueue* _task_queue; member in G1ParScanThreadState
118 bool queue_is_empty() const { return _task_queue->is_empty(); } in queue_is_empty()
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/command_lib/storage/tasks/ |
| H A D | task_graph_executor.py | 146 self._task_queue = multiprocessing.Queue(maxsize=1)
167 args=(self._task_queue, self._task_output_queue,
211 self._task_queue.put(task_wrapper, block=reached_process_limit)
309 self._task_queue.put(_SHUTDOWN)
317 self._task_queue.close()
|
| /dports/benchmarks/py-locust/locustio-0.11.0/locust/ |
| H A D | core.py | 302 self._task_queue = []
357 if not self._task_queue:
386 task = self._task_queue.pop(0)
414 self._task_queue.insert(0, task)
416 self._task_queue.append(task)
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/core/util/ |
| H A D | parallel.py | 408 self._task_queue = queue.Queue()
416 thread = _WorkerThread(self._task_queue, self._results_map)
425 self._task_queue.put(_ThreadTask(task))
432 self._task_queue.put(_STOP_WORKING)
|
| /dports/lang/micropython/micropython-1.17/extmod/ |
| H A D | moduasyncio.c | 199 mp_obj_t _task_queue = mp_obj_dict_get(uasyncio_context, MP_OBJ_NEW_QSTR(MP_QSTR__task_queue)); in task_cancel() local
209 dest[0] = _task_queue; in task_cancel()
215 task_queue_remove(_task_queue, MP_OBJ_FROM_PTR(self)); in task_cancel()
217 dest[0] = _task_queue; in task_cancel()
|
| /dports/devel/py-kazoo/kazoo-2.5.0/kazoo/recipe/ |
| H A D | cache.py | 49 self._task_queue = client.handler.queue_impl()
95 self._task_queue.put(self._STOP)
177 self._task_queue.put((func, args, kwargs))
182 cb = self._task_queue.get()
|
| /dports/devel/py-gevent/gevent-21.8.0/src/gevent/ |
| H A D | threadpool.py | 94 self._task_queue = threadpool.task_queue # type:gevent._threading.Queue
95 self._task_queue_cookie = self._task_queue.allocate_cookie()
179 task_queue_get = self._task_queue.get
182 task_queue_done = self._task_queue.task_done
216 self._task_queue = None
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/gc_implementation/g1/ |
| H A D | concurrentMark.inline.hpp | 238 if (!_task_queue->push(obj)) { in push()
252 bool success = _task_queue->push(obj); in push()
256 statsOnly( int tmp_size = _task_queue->size(); in push()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/src/share/vm/gc_implementation/g1/ |
| H A D | concurrentMark.inline.hpp | 238 if (!_task_queue->push(obj)) { in push()
252 bool success = _task_queue->push(obj); in push()
256 statsOnly( int tmp_size = _task_queue->size(); in push()
|
| /dports/benchmarks/py-locust/locustio-0.11.0/locust/test/ |
| H A D | test_runners.py | 307 self._task_queue = [
330 l.task_set._task_queue = [l.task_set.will_error, l.task_set.will_stop]
332 l.task_set._task_queue = [l.task_set.will_error, l.task_set.will_stop]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/hotspot/share/gc/g1/ |
| H A D | g1ConcurrentMark.inline.hpp | 117 if (!_task_queue->push(task_entry)) { in push()
125 bool success = _task_queue->push(task_entry); in push()
|