Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 35) 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_file.rs63 let task = || async { localVariable
89 let task = || async { localVariable
117 let task = || async { localVariable
148 let task = || async { localVariable
Dylong_tokio_multi_threaded.rs59 let task = || async { localVariable
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp47 napi_value task = nullptr; in GeneratorTask() local
87 Task* task = Task::GenerateTask(env, thisValue, func, taskName, args, argc); in CreateTaskObject() local
114 Task* task = nullptr; in CreateNullTaskObject() local
162 Task* task = taskManager.GetTask(taskId); variable
292 Task* task = new Task(); variable
304 Task* task = new Task(); variable
316 Task* task = new Task(); variable
389 Task* task = new Task(); variable
498 Task* task = new Task(); variable
522 Task* task = new Task(); variable
[all …]
Dtest.cpp182 Task* task = reinterpret_cast<Task*>(handle->data); in UpdateGroupInfoByResult() local
329 Task* task = new Task(); in CancelTask() local
364 Task* task = new Task(); in NotifyWorkerIdle() local
381 Task* task = new Task(); in EnqueueTaskId() local
402 Task* task = new Task(); in GetTaskByPriority() local
427 Task* task = new Task(); in RestoreWorker() local
476 Task* task = new Task(); in NotifyDependencyTaskInfo() local
500 Task* task = new Task(); in StoreTaskDependency() local
538 Task* task = new Task(); in RemoveTaskDependency() local
565 Task* task = new Task(); in ReleaseTaskData() local
[all …]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dtaskpool.cpp206 auto task = TaskManager::GetInstance().GetTask(taskId); in TerminateTask() local
247 Task* task = nullptr; in Execute() local
270 …Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::FUNCTION_TASK); in Execute() local
284 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); in DelayTask() local
337 Task* task = nullptr; in ExecuteDelayed() local
413 Task* task = nullptr; in ExecuteGroup() local
436 auto task = static_cast<Task*>(req->data); in HandleTaskResult() local
454 void TaskPool::HandleTaskResultCallback(Task* task) in HandleTaskResultCallback()
505 void TaskPool::TriggerTask(Task* task) in TriggerTask()
533 void TaskPool::UpdateGroupInfoByResult(napi_env env, Task* task, napi_value res, bool success) in UpdateGroupInfoByResult()
[all …]
Dworker.cpp143 auto task = std::move(worker->debuggerQueue_.front()); in HandleDebuggerTask() local
149 void Worker::DebuggerOnPostTask(std::function<void()>&& task) in DebuggerOnPostTask()
262 workerEngine->SetDebuggerPostTaskFunc([this](std::function<void()>&& task) { in PrepareForWorkerInstance()
382 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first); in PerformTask() local
445 void Worker::NotifyTaskResult(napi_env env, Task* task, napi_value result) in NotifyTaskResult()
467 void Worker::NotifyHandleTaskResult(Task* task) in NotifyHandleTaskResult()
502 Task* task = static_cast<Task*>(data); in TaskResultCallback() local
544 bool Worker::InitTaskPoolFunc(napi_env env, napi_value func, Task* task) in InitTaskPoolFunc()
589 void Worker::UpdateLongTaskInfo(Task* task) in UpdateLongTaskInfo()
609 void Worker::HandleFunctionException(napi_env env, Task* task) in HandleFunctionException()
Dtask.cpp77 Task* task = GenerateTask(env, thisVar, func, name, args, argc); in TaskConstructor() local
99 Task* task; in LongTaskConstructor() local
107 Task* task = static_cast<Task*>(data); in TaskDestructor() local
140 Task* task = static_cast<Task*>(arg); in CleanupHookFunc() local
168 Task* task = new Task(env, TaskType::TASK, nameStr); in GenerateTask() local
217 Task* task = new Task(env, type, nameStr); in GenerateFunctionTask() local
228 napi_value Task::GetTaskInfoPromise(napi_env env, napi_value task, TaskType taskType, Priority prio… in GetTaskInfoPromise()
238 TaskInfo* Task::GetTaskInfo(napi_env env, napi_value task, Priority priority) in GetTaskInfo()
300 Task* task = nullptr; in SetTransferList() local
362 Task* task = nullptr; in SetCloneList() local
[all …]
Dtask_group.cpp111 Task* task = nullptr; in AddTask() local
128 …Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::GROUP_FUNCTION… in AddTask() local
184 Task* task = nullptr; in NotifyGroupTask() local
Dsequence_runner.cpp138 Task* task = nullptr; in Execute() local
187 void SequenceRunner::RemoveWaitingTask(Task* task) in RemoveWaitingTask()
Dthread.cpp39 auto task = [this]() { in Start() local
Dtask_manager.cpp597 Task* task = GetTask(taskId); in CancelTask() local
671 void TaskManager::CancelSeqRunnerTask(napi_env env, Task *task) in CancelSeqRunnerTask()
773 Task* task = GetTask(taskId); in EnqueueTaskId() local
980 auto task = reinterpret_cast<Task*>(taskId); in DecreaseRefCount() local
998 napi_value TaskManager::NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task) in NotifyCallbackExecute()
1348 void TaskManager::ReleaseTaskData(napi_env env, Task* task, bool shouldDeleteTask) in ReleaseTaskData()
1396 void TaskManager::ReleaseCallBackInfo(Task* task) in ReleaseCallBackInfo()
1440 void TaskManager::StoreTask(uint64_t taskId, Task* task) in StoreTask()
1492 bool TaskManager::PostTask(std::function<void()> task, const char* taskName, Priority priority) in PostTask()
1549 Task* task = TaskManager::GetInstance().GetTask(taskId); in ReleaseTaskGroupData() local
[all …]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dblock_on.rs78 async fn task() -> i32 { in sdv_block_on_nest_spawn_spawn_blocking() function
108 async fn task() -> i32 { in sdv_block_on_nest_spawn_and_spawn() function
149 async fn task() -> i32 { in sdv_block_on_nest_spawn_nest_spawn() function
183 async fn task() -> i32 { in sdv_block_on_nest_spawn_nest_spawn2() function
203 async fn task() -> i32 { in sdv_block_on_nest_batch_spawn() function
228 async fn task() -> usize { in sdv_block_on_nest_await_spawn() function
262 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/rust/ylong_http/ylong_http/tests/
Dsdv_http_body.rs84 let mut task = ChunkBody::from_async_reader(content.as_slice()); in sdv_async_chunk_body_from_async_reader() localVariable
111 let mut task = ChunkBody::from_bytes(content.as_slice()); in sdv_async_chunk_body_from_bytes() localVariable
140 let mut task = ChunkBody::from_bytes(content.as_slice()).set_trailer(headers); in sdv_chunk_body_encode_trailer_0() localVariable
/commonlibrary/c_utils/base/src/
Dthread_pool.cpp103 Task task; in ScheduleTask() local
123 Task task = ScheduleTask(); in WorkInThread() local
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
Dlib.rs43 pub mod task; module
Dspawn.rs53 let task = BlockingTask(Some(task)); localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
Dqueue.rs232 let task = self.buffer[(pos & MASK) as usize].get(); in pop_front() localVariable
322 let task = unsafe { ptr::read(task_ptr).assume_init() }; in push_overflowed() localVariable
391 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
404 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
438 let task = self.pop_front().unwrap(); in drop() localVariable
461 let task = unsafe { ptr::read(task_ptr.get()).assume_init() }; in push_batch() localVariable
520 let task = list in pop_front() localVariable
615 let task = self.pop_front(); in pop_front_and_release() localVariable
622 let task = self.steal_into(other); in steal_into_and_release() localVariable
/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
545 let mut task = WriteData::new(name, &mut self.name_idx, buf); in encode_name() localVariable
560 let mut task = WriteData::new(colon, &mut self.colon_idx, buf); in encode_colon() localVariable
575 let mut task = WriteData::new(value, &mut self.value_idx, buf); in encode_value() localVariable
624 let mut task = WriteData::new(sp, &mut self.src_idx, buf); in encode() localVariable
640 let mut task = WriteData::new(crlf, &mut self.src_idx, buf); in encode() localVariable
/commonlibrary/rust/ylong_runtime/ylong_ffrt/src/
Dlib.rs18 mod task; module
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
Dylong_tokio_spawn.rs43 fn task() { in task() function
/commonlibrary/rust/ylong_http/ylong_http/src/body/
Dchunk.rs525 let mut task = WriteData::new(src, &mut self.chunk_idx, dst); in data_encode() localVariable
542 let mut task = WriteData::new(src, &mut self.chunk_idx, dst); in tail_encode() localVariable
585 let mut task = WriteData::new(hex, &mut self.src_idx, buf); in encode() localVariable
601 let mut task = WriteData::new(crlf, &mut self.src_idx, buf); in encode() localVariable
616 let mut task = WriteData::new(src, &mut self.src_idx, buf); in encode() localVariable
1479 let mut task = ChunkBody::from_bytes(content.as_slice()).set_trailer(headers); in ut_chunk_body_encode_trailer_0() localVariable
1499 let mut task = ChunkBody::from_bytes(content.as_slice()); in ut_chunk_body_encode_0() localVariable
1520 let mut task = ChunkBody::from_reader(content.as_slice()); in ut_chunk_body_encode_1() localVariable
1550 let mut task = ChunkBody::from_bytes(content.as_slice()); in asnyc_chunk_body_encode_0() localVariable
1582 let mut task = ChunkBody::from_async_reader(content.as_slice()); in asnyc_chunk_body_encode_1() localVariable
/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

12