| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_schedule.rs | 29 handlers.push(runtime.spawn(async move {
51 handlers.push(ylong_runtime::spawn(async move {
|
| H A D | ylong_tokio_mutex.rs | 40 handlers.push(runtime.spawn(async move {
70 handlers.push(ylong_runtime::spawn(async move {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_signal.rs | 43 handles.push(ylong_runtime::spawn(async move { in run_multi_thread_signal()
62 handles.push(ylong_runtime::spawn(async move { in run_multi_thread_signal()
|
| H A D | ylong_runtime_tcp.rs | 61 handlers.push(ylong_runtime::spawn(ylong_tcp_server(addr))); in ylong_tcp_send_recv()
62 handlers.push(ylong_runtime::spawn(ylong_tcp_client(addr))); in ylong_tcp_send_recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | spawn.rs | 27 use crate::ffrt::spawner::spawn;
54 spawn(task, builder)
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_read.rs | 24 /// 1. use global runtime to spawn a task.
63 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_to_string()
74 let client = ylong_runtime::spawn(async move { in sdv_buf_reader_read_to_string()
|
| H A D | async_dir.rs | 27 let handle = ylong_runtime::spawn(async move { in sdv_async_dir()
62 let handle = ylong_runtime::spawn(async move { in sdv_async_dir_create_remove()
|
| H A D | timer_test.rs | 42 handles.push(ylong_runtime::spawn(async move {
71 let handle = ylong_runtime::spawn(async move { sleep_until(Instant::now()) }); in sdv_sleep_drop_out_context()
125 let handle = ylong_runtime::spawn(async move { in sdv_sleep_poll()
|
| /third_party/node/test/parallel/ |
| H A D | test-child-process-cwd.js | 29 const { spawn } = require('child_process');
36 const child = spawn(...common.pwdCommand, options);
|
| H A D | test-inspector-port-zero.js | 7 const { spawn } = require('child_process');
11 const proc = spawn(process.execPath, args);
|
| /third_party/node/test/async-hooks/ |
| H A D | test-pipewrap.js | 11 const { spawn } = require('child_process');
19 const nodeVersionSpawn = spawn(process.execPath, [ '--version' ]);
40 'processwrap when sleep.spawn was called');
45 checkInvocations(x, { init: 1 }, 'pipe wrap when sleep.spawn was called');
85 'pipe wrap when sleep.spawn was called');
87 'pipe wrap when sleep.spawn was called');
89 'pipe wrap when sleep.spawn was called');
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | popen_forkserver.py | 9 from . import spawn namespace
42 prep_data = spawn.get_preparation_data(process_obj._name)
|
| /third_party/python/Lib/distutils/ |
| H A D | msvc9compiler.py | 492 self.spawn([self.rc] + pp_opts +
513 self.spawn([self.mc] +
518 self.spawn([self.rc] +
531 self.spawn([self.cc] + compile_opts + pp_opts +
558 self.spawn([self.lib] + lib_args)
639 self.spawn([self.linker] + ld_args)
653 self.spawn(['mt.exe', '-nologo', '-manifest',
|
| H A D | cmd.py | 362 def spawn(self, cmd, search_path=1, level=1): member in Command
364 from distutils.spawn import spawn namespace
365 spawn(cmd, search_path, dry_run=self.dry_run)
|
| H A D | cygwinccompiler.py | 59 from distutils.spawn import find_executable
162 self.spawn(["windres", "-i", src, "-o", obj])
167 self.spawn(self.compiler_so + cc_args + [src, '-o', obj] +
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | mix.rs | 426 let handle = ylong_runtime::spawn(async move { in ut_mix_set_async_reader()
453 let handle = ylong_runtime::spawn(async move { in ut_mix_set_reader_then_async_data()
480 let handle = ylong_runtime::spawn(async move { in ut_mix_set_bytes_then_async_data()
507 let handle = ylong_runtime::spawn(async move { in ut_mix_set_owned_then_async_data()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 138 let handle = crate::spawn(async move { in poll_flush()
184 let handle = crate::spawn(async move { in poll_flush()
231 let handle = crate::spawn(async move { in poll_flush()
281 let handle = crate::spawn(async move { in poll_flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | join_set.rs | 25 use crate::spawn::spawn_async;
45 /// set.spawn(async move { 0 });
141 /// immediately when `spawn` is called.
152 /// let cancel_handle = set.spawn(async move { 1 });
156 pub fn spawn<T>(&mut self, task: T) -> CancelHandle in spawn() functions
171 Some(builder) => builder.spawn(task), in spawn_inner()
201 /// set.spawn(async move { 1 });
238 /// set.spawn(async move { 1 });
259 /// set.spawn(async move { 1 });
269 /// spawn task
413 pub fn spawn<T>(&mut self, task: T) -> CancelHandle spawn() functions
[all...] |
| H A D | mod.rs | 141 pub fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn() functions
147 TaskBuilder::new().spawn(task) in spawn()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| H A D | Parallel.h | 74 void spawn(std::function<void()> f);
114 TG.spawn([=, &Comp, &TG] { in parallel_quick_sort()
131 // the number of spawn() calls. We'll create up to 1024 tasks here. in parallel_for_each()
140 TG.spawn([=, &Fn] { std::for_each(Begin, Begin + TaskSize, Fn); }); in parallel_for_each()
155 TG.spawn([=, &Fn] { in parallel_for_each_n()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | part.rs | 398 let handle = ylong_runtime::spawn(async move { in ut_mime_part_encoder_body_from_owned_then_async_data()
427 let handle = ylong_runtime::spawn(async move { in ut_mime_part_encoder_body_from_bytes_then_async_data()
456 let handle = ylong_runtime::spawn(async move { in ut_mime_part_encoder_common_then_async_data()
|
| /third_party/python/Lib/distutils/command/ |
| H A D | upload.py | 17 from distutils.spawn import spawn namespace
91 spawn(gpg_args,
|
| /third_party/rust/crates/once_cell/src/ |
| H A D | imp_std.rs | 332 thread::spawn(move || { in stampede_once()
394 let t1 = thread::spawn(move || { in wait_for_force_to_finish()
404 let t2 = thread::spawn(|| { in wait_for_force_to_finish()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 73 spawn,
101 spawn,
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | mutex.rs | 193 use crate::{block_on, spawn};
256 spawn(async move { in ut_mutex_try_lock_02()
|