| /dports/www/flexget/Flexget-3.2.18/flexget/ |
| H A D | task_queue.py | 22 self.run_queue: 'queue.PriorityQueue[Task]' = queue.PriorityQueue()
41 self.current_task = self.run_queue.get(timeout=0.5)
57 self.run_queue.task_done()
60 remaining_jobs = self.run_queue.qsize()
73 self.run_queue.put(task)
76 return self.run_queue.qsize()
86 if self.run_queue.qsize():
89 self.run_queue.qsize(),
|
| /dports/devel/py-pyopencl/pyopencl-2018.2/pyopencl/ |
| H A D | bitonic_sort.py | 112 run_queue = self.sort_b_prepare_wl(
118 knl, nt, wg, aux = run_queue[0]
129 for knl, nt, wg, _ in run_queue[1:]:
141 for knl, nt, wg, _ in run_queue[1:]:
170 run_queue = []
210 run_queue.append((prg.run, size, (wg,), True))
234 run_queue.append((prg.run, nthreads, None, False,))
239 return run_queue
|
| /dports/sysutils/syslinux/syslinux-6.03/gpxe/src/core/ |
| H A D | process.c | 34 static LIST_HEAD ( run_queue );
48 list_add_tail ( &process->list, &run_queue ); in process_add()
82 list_for_each_entry ( process, &run_queue, list ) { in step()
84 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/skia/bench/ |
| H A D | GrMemoryPoolBench.cpp | 68 static void run_queue(GrMemoryPool* pool, int loops) { in run_queue() function
200 DEF_BENCH( return new GrMemoryPoolBench("queue_aligned_lg", run_queue<Aligned>, kLargePool…
201 DEF_BENCH( return new GrMemoryPoolBench("queue_aligned_sm", run_queue<Aligned>, kSmallPool…
202 DEF_BENCH( return new GrMemoryPoolBench("queue_aligned_ref", run_queue<Aligned>, 0); )
203 DEF_BENCH( return new GrMemoryPoolBench("queue_unaligned_lg", run_queue<Unaligned>, kLargePool…
204 DEF_BENCH( return new GrMemoryPoolBench("queue_unaligned_sm", run_queue<Unaligned>, kSmallPool…
205 DEF_BENCH( return new GrMemoryPoolBench("queue_unaligned_ref", run_queue<Unaligned>, 0); )
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/skia/bench/ |
| H A D | GrMemoryPoolBench.cpp | 64 static void run_queue(GrMemoryPool* pool, int loops) { in run_queue() function
196 DEF_BENCH( return new GrMemoryPoolBench("queue_aligned_lg", run_queue<Aligned>, kLargePool…
197 DEF_BENCH( return new GrMemoryPoolBench("queue_aligned_sm", run_queue<Aligned>, kSmallPool…
198 DEF_BENCH( return new GrMemoryPoolBench("queue_aligned_ref", run_queue<Aligned>, 0); )
199 DEF_BENCH( return new GrMemoryPoolBench("queue_unaligned_lg", run_queue<Unaligned>, kLargePool…
200 DEF_BENCH( return new GrMemoryPoolBench("queue_unaligned_sm", run_queue<Unaligned>, kSmallPool…
201 DEF_BENCH( return new GrMemoryPoolBench("queue_unaligned_ref", run_queue<Unaligned>, 0); )
|
| /dports/emulators/qemu42/qemu-4.2.1/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/emulators/qemu-powernv/qemu-powernv-3.0.50/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/emulators/qemu5/qemu-5.2.0/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/net/ipxe/ipxe-2265a65/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/emulators/qemu-utils/qemu-4.2.1/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/emulators/qemu-guest-agent/qemu-5.0.1/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/emulators/qemu/qemu-6.2.0/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/emulators/qemu60/qemu-6.0.0/roms/ipxe/src/core/ |
| H A D | process.c | 39 static LIST_HEAD ( run_queue );
64 list_add_tail ( &process->list, &run_queue ); in process_add()
103 if ( ( process = list_first_entry ( &run_queue, struct process, in step()
110 list_add_tail ( &process->list, &run_queue ); in step()
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp3/tools/utils/ |
| H A D | run_testbenches.py | 221 def run_sim_queue(run_queue, out_queue, simulator, basedir, setupenv): argument
226 while not run_queue.empty():
227 (name, path) = run_queue.get()
240 run_queue.task_done()
258 run_queue = Queue(maxsize=0)
264 run_queue.put((name, path))
268 num_sims = run_queue.qsize()
273 …worker = Thread(target=run_sim_queue, args=(run_queue, out_queue, args.simulator, args.basedir, ar…
287 while not run_queue.empty():
288 (name, path) = run_queue.get()
|
| /dports/devel/sentry-cli/sentry-cli-1.71.0/cargo-crates/tokio-1.13.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/tokio-1.14.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/tokio-1.15.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/tokio-1.14.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/x11-wm/leftwm/leftwm-0.2.11/cargo-crates/tokio-1.14.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/dns/encrypted-dns-server/encrypted-dns-server-0.9.1/cargo-crates/tokio-1.12.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/editors/helix/helix-0.5.0/cargo-crates/tokio-1.12.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/tokio-1.12.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/tokio-1.14.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/net/krill/krill-0.9.4/cargo-crates/tokio-1.12.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|
| /dports/net/oha/oha-0.4.7/cargo-crates/tokio-1.12.0/src/runtime/thread_pool/ |
| H A D | worker.rs | 101 run_queue: queue::Local<Arc<Shared>>, field
200 let (steal, run_queue) = queue::local(); in create()
208 run_queue, in create()
447 core.run_queue.push_back(task, self.worker.inject()); in run_task()
514 if core.run_queue.is_stealable() { in park_timeout()
540 self.lifo_slot.take().or_else(|| self.run_queue.pop()) in next_local_task()
563 .steal_into(&mut self.run_queue, &mut self.stats) in steal_work()
595 if self.lifo_slot.is_some() || self.run_queue.has_tasks() { in transition_to_parked()
733 core.run_queue.push_back(task, &self.inject); in schedule_local()
741 core.run_queue.push_back(prev, &self.inject); in schedule_local()
|