| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_thread_pool_test.cpp | 130 auto task = std::bind(TestFuncAddOneTime, i); variable
136 auto task = std::bind(TestFuncSubOneTime, i); variable
160 auto task = std::bind(TestFuncAddOneTime, i); variable
166 auto task = std::bind(TestFuncSubOneTime, i); variable
208 auto task = std::bind(TestFuncAddWait, i); variable
214 auto task = std::bind(TestFuncSubWait, i); variable
246 auto task = std::bind(TestFuncAddWait, i); variable
252 auto task = std::bind(TestFuncSubWait, i); variable
300 auto task = std::bind(TestFuncGetName, poolName); variable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_async_file.rs | 37 let task = || async { localVariable
61 let task = || async { localVariable
88 let task = || async { localVariable
|
| D | ylong_tokio_multi_threaded.rs | 59 let task = || async { localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | block_on.rs | 87 async fn task() -> i32 { in sdv_block_on_nest_spawn_spawn_blocking() function
117 async fn task() -> i32 { in sdv_block_on_nest_spawn_and_spawn() function
158 async fn task() -> i32 { in sdv_block_on_nest_spawn_nest_spawn() function
192 async fn task() -> i32 { in sdv_block_on_nest_spawn_nest_spawn2() function
212 async fn task() -> i32 { in sdv_block_on_nest_batch_spawn() function
237 async fn task() -> usize { in sdv_block_on_nest_await_spawn() function
271 async fn task() -> usize { in sdv_block_on_nest_await_spawn_bug_test() function
|
| D | task_cancel.rs | 35 let task = ylong_runtime::spawn(async move { in sdv_task_cancel_simple() localVariable
57 let task = ylong_runtime::spawn(async move { 1 }); in sdv_task_cancel_failed() localVariable
|
| D | timer_test.rs | 83 let task = Task {}; in simulate() localVariable
|
| /commonlibrary/c_utils/base/src/ |
| D | thread_pool.cpp | 103 Task task; in ScheduleTask() local
123 Task task = ScheduleTask(); in WorkInThread() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | blocking_pool.rs | 200 let task = BlockingTask(Some(task)); in spawn_blocking() localVariable
529 let task = BlockingTask(Some(move || { in ut_blocking_pool_spawner_spawn() localVariable
542 let task = BlockingTask(Some(move || { in ut_blocking_pool_spawner_spawn() localVariable
556 let task = BlockingTask(Some(move || { in ut_blocking_pool_spawner_spawn() localVariable
571 let task = BlockingTask(Some(move || { in ut_blocking_pool_spawner_spawn() localVariable
601 let task = BlockingTask(Some(move || { in ut_blocking_pool_spawner_spawn() localVariable
|
| D | queue.rs | 224 let task = self.buffer[(pos & MASK) as usize].get(); in pop_front() localVariable
315 let task = unsafe { ptr::read(task_ptr).assume_init() }; in push_overflowed() localVariable
385 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
397 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
440 let task = unsafe { ptr::read(task_ptr.get()).assume_init() }; in push_batch() localVariable
499 let task = list.pop_front(); in pop_front() localVariable
|
| D | async_pool.rs | 193 let task = { in dequeue() localVariable
202 let task = if limit == LOCAL_QUEUE_CAP { in dequeue() localVariable
490 let task = Task(raw_task); in spawn_with_ref() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/request/ |
| D | encoder.rs | 482 let mut task = WriteData::new(version, &mut self.src_idx, buf); in encode() localVariable
535 let mut task = WriteData::new(name, &mut self.name_idx, buf); in encode() localVariable
549 let mut task = WriteData::new(colon, &mut self.colon_idx, buf); in encode() localVariable
563 let mut task = WriteData::new(value, &mut self.value_idx, buf); in encode() localVariable
612 let mut task = WriteData::new(sp, &mut self.src_idx, buf); in encode() localVariable
628 let mut task = WriteData::new(crlf, &mut self.src_idx, buf); in encode() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_ffrt/src/ |
| D | lib.rs | 19 mod task; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_spawn.rs | 43 fn task() { in task() function
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | lib.rs | 56 pub mod task; module
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_group.cpp | 80 napi_value task = nullptr; in AddTask() local
|
| D | task.cpp | 50 void Task::CreateTaskByFunc(napi_env env, napi_value task, napi_value func, napi_value* args, size_… in CreateTaskByFunc()
|
| D | worker.cpp | 109 void Worker::DebuggerOnPostTask(std::function<void()>&& task) in DebuggerOnPostTask()
|
| D | taskpool.cpp | 158 napi_value task = NapiHelper::GetReferenceValue(env, *iter); in ExecuteGroup() local
|
| D | task_manager.cpp | 563 TaskInfo* TaskManager::GenerateTaskInfoFromTask(napi_env env, napi_value task, uint32_t executeId) in GenerateTaskInfoFromTask()
797 void TaskGroupManager::AddTask(uint32_t groupId, napi_ref task) in AddTask()
827 for (napi_ref task : iter->second) { in ClearTasks() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | addr.rs | 153 let task = spawn_blocking(move || { in to_socket_addrs() localVariable
170 let task = spawn_blocking(move || { in to_socket_addrs() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | chunk.rs | 599 let mut task = WriteData::new(src, &mut self.chunk_idx, dst); in data_encode() localVariable
616 let mut task = WriteData::new(src, &mut self.chunk_idx, dst); in tail_encode() localVariable
659 let mut task = WriteData::new(hex, &mut self.src_idx, buf); in encode() localVariable
675 let mut task = WriteData::new(crlf, &mut self.src_idx, buf); in encode() localVariable
690 let mut task = WriteData::new(src, &mut self.src_idx, buf); in encode() localVariable
1521 let mut task = ChunkBody::from_bytes(content.as_slice()).set_trailer(headers); in ut_chunk_body_encode_trailer_0() localVariable
1541 let mut task = ChunkBody::from_bytes(content.as_slice()); in ut_chunk_body_encode_0() localVariable
1562 let mut task = ChunkBody::from_reader(content.as_slice()); in ut_chunk_body_encode_1() localVariable
1584 let mut task = ChunkBody::from_bytes(content.as_slice()); in ut_asnyc_chunk_body_encode_0() localVariable
1608 let mut task = ChunkBody::from_async_reader(content.as_slice()); in ut_asnyc_chunk_body_encode_1() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | timer.rs | 259 let task = time::periodic_schedule(closure, Some(10), Duration::from_nanos(20_000_000)); in ut_new_timer_schedule() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| D | core.rs | 206 let task = Task(raw_task); in spawn_task_ffrt() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test_taskpool.cpp | 235 napi_value task = NapiHelper::CreateUint32(env, taskId); variable
283 napi_value task = nullptr; variable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | task_handle.rs | 31 task: NonNull<TaskMngInfo<T, S>>, field
|