Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 28) sorted by relevance

12

/commonlibrary/c_utils/base/test/unittest/common/
Dutils_thread_pool_test.cpp130 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/
Dylong_tokio_async_file.rs37 let task = || async { localVariable
61 let task = || async { localVariable
88 let task = || async { localVariable
Dylong_tokio_multi_threaded.rs59 let task = || async { localVariable
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dworker.cpp118 auto task = std::move(worker->debuggerQueue_.front()); in HandleDebuggerTask() local
124 void Worker::DebuggerOnPostTask(std::function<void()>&& task) in DebuggerOnPostTask()
285 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first); in PerformTask() local
323 void Worker::NotifyTaskResult(napi_env env, Task* task, napi_value result) in NotifyTaskResult()
344 void Worker::NotifyHandleTaskResult(Task* task) in NotifyHandleTaskResult()
372 Task* task = static_cast<Task*>(data); in TaskResultCallback() local
414 bool Worker::InitTaskPoolFunc(napi_env env, napi_value func, Task* task) in InitTaskPoolFunc()
447 void Worker::HandleFunctionException(napi_env env, Task* task) in HandleFunctionException()
Dtaskpool.cpp122 auto task = TaskManager::GetInstance().GetTask(resultInfo->taskId); in ExecuteCallback() local
171 Task* task = nullptr; in Execute() local
191 …Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::FUNCTION_TASK); in Execute() local
205 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); in DelayTask() local
248 Task* task = nullptr; in ExecuteDelayed() local
307 Task* task = nullptr; in ExecuteGroup() local
330 auto task = static_cast<Task*>(req->data); in HandleTaskResult() local
371 void TaskPool::TriggerTask(Task* task) in TriggerTask()
391 void TaskPool::UpdateGroupInfoByResult(napi_env env, Task* task, napi_value res, bool success) in UpdateGroupInfoByResult()
428 void TaskPool::ExecuteTask(napi_env env, Task* task, Priority priority) in ExecuteTask()
Dtask.cpp71 Task* task = GenerateTask(env, thisVar, func, name, args, argc); in TaskConstructor() local
80 Task* task = static_cast<Task*>(data); in TaskDestructor() local
97 Task* task = new Task(env, TaskType::TASK, nameStr); in GenerateTask() local
146 Task* task = new Task(env, type, nameStr); in GenerateFunctionTask() local
157 napi_value Task::GetTaskInfoPromise(napi_env env, napi_value task, TaskType taskType, Priority prio… in GetTaskInfoPromise()
166 TaskInfo* Task::GetTaskInfo(napi_env env, napi_value task, TaskType taskType, Priority priority) in GetTaskInfo()
238 Task* task = nullptr; in SetTransferList() local
297 Task* task = nullptr; in SetCloneList() local
335 Task* task = static_cast<Task*>(data); in IsCanceled() local
401 Task* task = nullptr; in SendData() local
[all …]
Dtask_group.cpp97 Task* task = nullptr; in AddTask() local
106 …Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::GROUP_FUNCTION… in AddTask() local
142 Task* task = nullptr; in NotifyGroupTask() local
Dtask_manager.cpp483 Task* task = GetTask(taskId); in CancelTask() local
733 napi_value TaskManager::NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task) in NotifyCallbackExecute()
793 auto task = reinterpret_cast<Task*>(taskIter->second); in IsDependendByTaskId() local
976 void TaskManager::ReleaseTaskData(napi_env env, Task* task) in ReleaseTaskData()
1003 void TaskManager::StoreTask(uint64_t taskId, Task* task) in StoreTask()
1048 Task* task = TaskManager::GetInstance().GetTask(taskId); in ReleaseTaskGroupData() local
1090 auto task = TaskManager::GetInstance().GetTask(taskId); in CancelGroupTask() local
1142 void TaskGroupManager::AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task) in AddTaskToSeqRunner()
1175 Task* task = seqRunner->seqRunnerTasks_.front(); in TriggerSeqRunner() local
Dsequence_runner.cpp99 Task* task = nullptr; in Execute() local
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dblock_on.rs87 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
Dtask_cancel.rs35 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
/commonlibrary/c_utils/base/test/benchmarktest/thread_pool_benchmark_test/
Dthread_pool_benchmark_test.cpp178 auto task = std::bind(TestFuncAddOneTime, i); in BENCHMARK_F() local
183 auto task = std::bind(TestFuncSubOneTime, i); in BENCHMARK_F() local
223 auto task = std::bind(TestFuncAddOneTime, i); in BENCHMARK_F() local
228 auto task = std::bind(TestFuncSubOneTime, i); in BENCHMARK_F() local
284 auto task = std::bind(TestFuncAddWait, i); in BENCHMARK_F() local
289 auto task = std::bind(TestFuncSubWait, i); in BENCHMARK_F() local
340 auto task = std::bind(TestFuncAddWait, i); in BENCHMARK_F() local
345 auto task = std::bind(TestFuncSubWait, i); in BENCHMARK_F() local
410 auto task = std::bind(TestFuncGetName, poolName); in BENCHMARK_F() local
/commonlibrary/c_utils/base/src/
Dthread_pool.cpp103 Task task; in ScheduleTask() local
123 Task task = ScheduleTask(); in WorkInThread() local
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp70 Task* task = taskManager.GetTask(taskId); variable
194 Task* task = new Task(); variable
206 Task* task = new Task(); variable
218 Task* task = new Task(); variable
284 Task* task = new Task(); variable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
Dblocking_pool.rs200 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
Dqueue.rs226 let task = self.buffer[(pos & MASK) as usize].get(); in pop_front() localVariable
317 let task = unsafe { ptr::read(task_ptr).assume_init() }; in push_overflowed() localVariable
387 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
399 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
442 let task = unsafe { ptr::read(task_ptr.get()).assume_init() }; in push_batch() localVariable
501 let task = list.pop_front(); in pop_front() localVariable
Dasync_pool.rs192 let task = { in dequeue() localVariable
201 let task = if limit == LOCAL_QUEUE_CAP { in dequeue() localVariable
485 let task = Task(raw_task); in spawn_with_ref() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
Dlib.rs44 pub mod task; module
/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/
Dencoder.rs484 let mut task = WriteData::new(version, &mut self.src_idx, buf); in encode() localVariable
537 let mut task = WriteData::new(name, &mut self.name_idx, buf); in encode() localVariable
551 let mut task = WriteData::new(colon, &mut self.colon_idx, buf); in encode() localVariable
565 let mut task = WriteData::new(value, &mut self.value_idx, buf); in encode() localVariable
614 let mut task = WriteData::new(sp, &mut self.src_idx, buf); in encode() localVariable
630 let mut task = WriteData::new(crlf, &mut self.src_idx, buf); in encode() localVariable
/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/
Dlib.rs19 mod task; module
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
Dylong_tokio_spawn.rs43 fn task() { in task() function
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
Daddr.rs153 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/
Dchunk.rs599 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
1618 let mut task = ChunkBody::from_bytes(content.as_slice()).set_trailer(headers); in ut_chunk_body_encode_trailer_0() localVariable
1638 let mut task = ChunkBody::from_bytes(content.as_slice()); in ut_chunk_body_encode_0() localVariable
1659 let mut task = ChunkBody::from_reader(content.as_slice()); in ut_chunk_body_encode_1() localVariable
1689 let mut task = ChunkBody::from_bytes(content.as_slice()); in asnyc_chunk_body_encode_0() localVariable
1721 let mut task = ChunkBody::from_async_reader(content.as_slice()); in asnyc_chunk_body_encode_1() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
Dtimer.rs259 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/
Dcore.rs206 let task = Task(raw_task); in spawn_task_ffrt() localVariable

12