| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/async-task-4.1.0/examples/ |
| H A D | spawn-on-thread.rs | 31 let schedule = move |runnable| s.upgrade().unwrap().send(runnable).unwrap(); in spawn_on_thread()
32 let (runnable, task) = async_task::spawn(future, schedule); in spawn_on_thread()
35 runnable.schedule(); in spawn_on_thread()
40 for runnable in receiver { in spawn_on_thread()
41 runnable.run(); in spawn_on_thread()
|
| H A D | spawn.rs | 23 for runnable in receiver { in spawn()
25 let _ignore_panic = catch_unwind(|| runnable.run()); in spawn()
33 let schedule = |runnable| QUEUE.send(runnable).unwrap(); in spawn()
34 let (runnable, task) = async_task::spawn(future, schedule); in spawn()
37 runnable.schedule(); in spawn()
|
| /dports/security/rustscan/RustScan-2.0.1/cargo-crates/async-task-4.0.3/examples/ |
| H A D | spawn-on-thread.rs | 31 let schedule = move |runnable| s.upgrade().unwrap().send(runnable).unwrap(); in spawn_on_thread()
32 let (runnable, task) = async_task::spawn(future, schedule); in spawn_on_thread()
35 runnable.schedule(); in spawn_on_thread()
40 for runnable in receiver { in spawn_on_thread()
41 runnable.run(); in spawn_on_thread()
|
| H A D | spawn.rs | 23 for runnable in receiver { in spawn()
25 let _ignore_panic = catch_unwind(|| runnable.run()); in spawn()
33 let schedule = |runnable| QUEUE.send(runnable).unwrap(); in spawn()
34 let (runnable, task) = async_task::spawn(future, schedule); in spawn()
37 runnable.schedule(); in spawn()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/async-task/examples/ |
| H A D | spawn-on-thread.rs | 31 let schedule = move |runnable| s.upgrade().unwrap().send(runnable).unwrap(); in spawn_on_thread()
32 let (runnable, task) = async_task::spawn(future, schedule); in spawn_on_thread()
35 runnable.schedule(); in spawn_on_thread()
40 for runnable in receiver { in spawn_on_thread()
41 runnable.run(); in spawn_on_thread()
|
| H A D | spawn.rs | 23 for runnable in receiver { in spawn()
25 let _ignore_panic = catch_unwind(|| runnable.run()); in spawn()
33 let schedule = |runnable| QUEUE.send(runnable).unwrap(); in spawn()
34 let (runnable, task) = async_task::spawn(future, schedule); in spawn()
37 runnable.schedule(); in spawn()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-task-4.0.3/examples/ |
| H A D | spawn-on-thread.rs | 31 let schedule = move |runnable| s.upgrade().unwrap().send(runnable).unwrap(); in spawn_on_thread()
32 let (runnable, task) = async_task::spawn(future, schedule); in spawn_on_thread()
35 runnable.schedule(); in spawn_on_thread()
40 for runnable in receiver { in spawn_on_thread()
41 runnable.run(); in spawn_on_thread()
|
| H A D | spawn.rs | 23 for runnable in receiver { in spawn()
25 let _ignore_panic = catch_unwind(|| runnable.run()); in spawn()
33 let schedule = |runnable| QUEUE.send(runnable).unwrap(); in spawn()
34 let (runnable, task) = async_task::spawn(future, schedule); in spawn()
37 runnable.schedule(); in spawn()
|
| /dports/textproc/jql/jql-3.0.6/cargo-crates/async-task-4.0.3/examples/ |
| H A D | spawn-on-thread.rs | 31 let schedule = move |runnable| s.upgrade().unwrap().send(runnable).unwrap(); in spawn_on_thread()
32 let (runnable, task) = async_task::spawn(future, schedule); in spawn_on_thread()
35 runnable.schedule(); in spawn_on_thread()
40 for runnable in receiver { in spawn_on_thread()
41 runnable.run(); in spawn_on_thread()
|
| H A D | spawn.rs | 23 for runnable in receiver { in spawn()
25 let _ignore_panic = catch_unwind(|| runnable.run()); in spawn()
33 let schedule = |runnable| QUEUE.send(runnable).unwrap(); in spawn()
34 let (runnable, task) = async_task::spawn(future, schedule); in spawn()
37 runnable.schedule(); in spawn()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/v8/tools/ |
| H A D | run_perf.py | 212 if runnable.name not in self.runnables:
213 self.runnables[runnable.name] = {
214 'graphs': runnable.graphs,
216 'timeout': runnable.timeout,
687 if runnable.process_size:
731 if runnable.path:
749 binary=runnable.binary,
752 timeout=runnable.timeout,
761 if runnable.process_size:
1058 def RunGenerator(runnable): argument
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.core/src/org/graalvm/compiler/core/ |
| H A D | GraalServiceThread.java | 33 private final Runnable runnable; field in GraalServiceThread
35 public GraalServiceThread(Runnable runnable) { in GraalServiceThread() argument
37 this.runnable = runnable; in GraalServiceThread()
44 runnable.run(); in run()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.core/src/org/graalvm/compiler/core/ |
| H A D | GraalServiceThread.java | 33 private final Runnable runnable; field in GraalServiceThread
35 public GraalServiceThread(Runnable runnable) { in GraalServiceThread() argument
37 this.runnable = runnable; in GraalServiceThread()
44 runnable.run(); in run()
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.core/src/org/graalvm/compiler/core/ |
| H A D | GraalServiceThread.java | 33 private final Runnable runnable; field in GraalServiceThread
35 public GraalServiceThread(Runnable runnable) { in GraalServiceThread() argument
37 this.runnable = runnable; in GraalServiceThread()
44 runnable.run(); in run()
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.bundles/bundles/org.eclipse.equinox.concurrent/src/org/eclipse/equinox/concurrent/future/ |
| H A D | ThreadsExecutor.java | 42 protected String createThreadName(IProgressRunnable<?> runnable) { in createThreadName() argument
43 return "ThreadsExecutor(" + runnable + ")"; //$NON-NLS-1$ //$NON-NLS-2$ in createThreadName()
93 IProgressRunnable<? extends ResultType> runnable,
95 Assert.isNotNull(runnable);
99 Thread thread = new Thread(createRunnable(sof, runnable),
100 createThreadName(runnable));
|
| /dports/x11/workrave/workrave-1.10.44/common/src/ |
| H A D | GlibThread.cc | 24 Thread::Thread(Runnable *runnable, bool autodelete) in Thread() argument
27 this->runnable = runnable; in Thread()
35 this->runnable = NULL; in Thread()
85 if (runnable != NULL) in run()
87 runnable->run(); in run()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/src/thrift/concurrency/ |
| H A D | PosixThreadFactory.cpp | 69 stdcxx::shared_ptr<Runnable> runnable) in PthreadThread() argument
81 this->Thread::runnable(runnable); in PthreadThread()
204 stdcxx::shared_ptr<Runnable> runnable() const { return Thread::runnable(); } in runnable() function in apache::thrift::concurrency::PthreadThread
206 void runnable(stdcxx::shared_ptr<Runnable> value) { Thread::runnable(value); } in runnable() function in apache::thrift::concurrency::PthreadThread
224 thread->runnable()->run(); in threadMain()
297 stdcxx::shared_ptr<Thread> PosixThreadFactory::newThread(stdcxx::shared_ptr<Runnable> runnable) con… in newThread()
303 runnable)); in newThread()
305 runnable->thread(result); in newThread()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/src/thrift/concurrency/ |
| H A D | PosixThreadFactory.cpp | 69 stdcxx::shared_ptr<Runnable> runnable) in PthreadThread() argument
81 this->Thread::runnable(runnable); in PthreadThread()
204 stdcxx::shared_ptr<Runnable> runnable() const { return Thread::runnable(); } in runnable() function in apache::thrift::concurrency::PthreadThread
206 void runnable(stdcxx::shared_ptr<Runnable> value) { Thread::runnable(value); } in runnable() function in apache::thrift::concurrency::PthreadThread
224 thread->runnable()->run(); in threadMain()
297 stdcxx::shared_ptr<Thread> PosixThreadFactory::newThread(stdcxx::shared_ptr<Runnable> runnable) con… in newThread()
303 runnable)); in newThread()
305 runnable->thread(result); in newThread()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/async-task-4.0.3/tests/ |
| H A D | waker_ready.rs | 109 runnable.run(); in wake()
117 runnable = chan.recv().unwrap(); in wake()
124 runnable.run(); in wake()
148 runnable.run(); in wake_by_ref()
156 runnable = chan.recv().unwrap(); in wake_by_ref()
163 runnable.run(); in wake_by_ref()
185 runnable.run(); in clone()
197 runnable = chan.recv().unwrap(); in clone()
198 runnable.run(); in clone()
224 runnable.run(); in wake_dropped()
[all …]
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/async-task-4.1.0/tests/ |
| H A D | waker_ready.rs | 109 runnable.run(); in wake()
117 runnable = chan.recv().unwrap(); in wake()
124 runnable.run(); in wake()
148 runnable.run(); in wake_by_ref()
156 runnable = chan.recv().unwrap(); in wake_by_ref()
163 runnable.run(); in wake_by_ref()
185 runnable.run(); in clone()
197 runnable = chan.recv().unwrap(); in clone()
198 runnable.run(); in clone()
224 runnable.run(); in wake_dropped()
[all …]
|
| /dports/security/rustscan/RustScan-2.0.1/cargo-crates/async-task-4.0.3/tests/ |
| H A D | waker_ready.rs | 109 runnable.run(); in wake()
117 runnable = chan.recv().unwrap(); in wake()
124 runnable.run(); in wake()
148 runnable.run(); in wake_by_ref()
156 runnable = chan.recv().unwrap(); in wake_by_ref()
163 runnable.run(); in wake_by_ref()
185 runnable.run(); in clone()
197 runnable = chan.recv().unwrap(); in clone()
198 runnable.run(); in clone()
224 runnable.run(); in wake_dropped()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/rust/async-task/tests/ |
| H A D | waker_ready.rs | 109 runnable.run(); in wake()
117 runnable = chan.recv().unwrap(); in wake()
124 runnable.run(); in wake()
148 runnable.run(); in wake_by_ref()
156 runnable = chan.recv().unwrap(); in wake_by_ref()
163 runnable.run(); in wake_by_ref()
185 runnable.run(); in clone()
197 runnable = chan.recv().unwrap(); in clone()
198 runnable.run(); in clone()
224 runnable.run(); in wake_dropped()
[all …]
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-task-4.0.3/tests/ |
| H A D | waker_ready.rs | 109 runnable.run();
117 runnable = chan.recv().unwrap();
124 runnable.run();
148 runnable.run();
156 runnable = chan.recv().unwrap();
163 runnable.run();
185 runnable.run();
197 runnable = chan.recv().unwrap();
198 runnable.run();
224 runnable.run();
[all …]
|
| /dports/textproc/jql/jql-3.0.6/cargo-crates/async-task-4.0.3/tests/ |
| H A D | waker_ready.rs | 109 runnable.run(); in wake()
117 runnable = chan.recv().unwrap(); in wake()
124 runnable.run(); in wake()
148 runnable.run(); in wake_by_ref()
156 runnable = chan.recv().unwrap(); in wake_by_ref()
163 runnable.run(); in wake_by_ref()
185 runnable.run(); in clone()
197 runnable = chan.recv().unwrap(); in clone()
198 runnable.run(); in clone()
224 runnable.run(); in wake_dropped()
[all …]
|
| /dports/graphics/krita/krita-4.4.8/libs/global/ |
| H A D | KisSharedThreadPoolAdapter.cpp | 38 void KisSharedThreadPoolAdapter::start(KisSharedRunnable *runnable, int priority) in start() argument
42 runnable->setSharedThreadPoolAdapter(this); in start()
43 m_parentPool->start(runnable, priority); in start()
48 bool KisSharedThreadPoolAdapter::tryStart(KisSharedRunnable *runnable) in tryStart() argument
52 runnable->setSharedThreadPoolAdapter(this); in tryStart()
53 const bool result = m_parentPool->tryStart(runnable); in tryStart()
|