worker (reference) in projects: commonlibrary

Repository(s)

Full Search		Search through all text tokens(words,strings,identifiers,numbers) in index.
Definition		Only finds symbol definitions(where e.g a variable(function,...) is defined).
Symbol		Only finds symbol(e.g. methods classes,function,variables).
File Path		Path of the source file(use "/").If you want just exact path,enclose it in "".Source files end with: .jar/.bz2/.a/.h/.java...
History		History log comments.
Type		Type of analyzer used to filter file types include with selected(e.g. just C sources).

Help

Searched refs:worker (Results 1 - 23 of 23) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A D	test_worker.cpp	26 #include "worker.h" 92 Worker worker = static_cast<Worker>(req->data); in WorkerOnMessage() local 93 ASSERT_NE(worker, nullptr); in WorkerOnMessage() 94 napi_env workerEnv = worker->GetWorkerEnv(); in WorkerOnMessage() 96 while (worker->workerMessageQueue_.DeQueue(&data)) { in WorkerOnMessage() 118 worker->PostMessageToHostInner(workerData); in WorkerOnMessage() 124 Worker worker = static_cast<Worker>(req->data); in HostOnMessage() local 125 ASSERT_NE(worker, nullptr); in HostOnMessage() 127 while (worker->hostMessageQueue_.DeQueue(&data)) { in HostOnMessage() 131 napi_env hostEnv = worker in HostOnMessage() 145 auto worker = reinterpret_cast<Worker>(data); WorkerThreadFunction() local 161 UpdateMainThreadWorkerFlag(Worker worker, bool isMainThreadWorker) UpdateMainThreadWorkerFlag() argument 166 InitHostHandle(Worker worker, uv_loop_t loop) InitHostHandle() argument 173 PostMessage(Worker worker, void message) PostMessage() argument 178 UpdateWorkerState(Worker worker, Worker::RunnerState state) UpdateWorkerState() argument 187 SetCloseWorkerProp(Worker worker, napi_env env) SetCloseWorkerProp() argument 200 SetWorkerRef(Worker worker, napi_env env) SetWorkerRef() argument 214 SetWorkerHostEnv(Worker worker, napi_env env, bool setNull) SetWorkerHostEnv() argument 223 UpdateHostState(Worker worker, Worker::HostState state) UpdateHostState() argument 232 SetMainThread(Worker worker, bool isMainThreadWorker) SetMainThread() argument 237 SetLimitedWorker(Worker worker, bool isLimitedWorker) SetLimitedWorker() argument 242 RemoveGlobalCallObject(Worker worker, napi_env env) RemoveGlobalCallObject() argument 266 TestHostOnMessageInner(Worker worker, napi_env env) TestHostOnMessageInner() argument 302 HostOnGlobalCall(Worker worker, napi_env env) HostOnGlobalCall() argument 345 HostOnGlobalCallInner001(Worker worker, napi_env env) HostOnGlobalCallInner001() argument 371 HostOnGlobalCallInner002(Worker worker, napi_env env) HostOnGlobalCallInner002() argument 400 HostOnGlobalCallInner003(Worker worker, napi_env env) HostOnGlobalCallInner003() argument 432 HostOnGlobalCallInner004(Worker worker, napi_env env) HostOnGlobalCallInner004() argument 467 HostOnGlobalCallInner005(Worker worker, napi_env env) HostOnGlobalCallInner005() argument 499 HostOnGlobalCallInner006(Worker worker, napi_env env) HostOnGlobalCallInner006() argument 531 HandleGlobalCall(Worker worker, napi_env env) HandleGlobalCall() argument 558 HostOnError(Worker worker, napi_env env) HostOnError() argument 582 HostOnErrorInner(Worker worker, napi_env env) HostOnErrorInner() argument 606 HostOnMessageErrorInner(Worker worker, napi_env env) HostOnMessageErrorInner() argument 618 PublishWorkerOverSignal(Worker worker, napi_env env) PublishWorkerOverSignal() argument 645 TestWorkerOnMessageInner(Worker worker, napi_env env) TestWorkerOnMessageInner() argument 678 HandleEventListeners(Worker worker, napi_env env) HandleEventListeners() argument 700 HandleHostException(Worker worker, napi_env env) HandleHostException() argument 747 PostMessageToHostInner(Worker worker, napi_env env) PostMessageToHostInner() argument 769 RemoveListenerInner(Worker worker, napi_env env) RemoveListenerInner() argument 814 ParentPortAddListenerInnerTest(Worker worker, napi_env env) ParentPortAddListenerInnerTest() argument 836 ParentPortRemoveListenerInnerTest(Worker worker, napi_env env) ParentPortRemoveListenerInnerTest() argument 873 ParentPortHandleEventListeners(Worker worker, napi_env env) ParentPortHandleEventListeners() argument 907 DebuggerOnPostTask(Worker worker, napi_env env) DebuggerOnPostTask() argument 934 CloseHostHandle(Worker* worker, napi_env env) CloseHostHandle() argument 951 ClearWorkerHandle(Worker* worker) ClearWorkerHandle() argument 1017 Worker* worker = nullptr; HWTEST_F() local 1040 Worker* worker = nullptr; HWTEST_F() local 1066 Worker* worker = nullptr; HWTEST_F() local 1095 Worker* worker = nullptr; HWTEST_F() local 1127 Worker* worker = nullptr; HWTEST_F() local 1157 Worker* worker = nullptr; HWTEST_F() local 1208 Worker* worker = nullptr; HWTEST_F() local 1234 Worker* worker = nullptr; HWTEST_F() local 1286 Worker* worker = nullptr; HWTEST_F() local 1322 Worker* worker = nullptr; HWTEST_F() local 1368 Worker* worker = nullptr; HWTEST_F() local 1406 Worker* worker = nullptr; HWTEST_F() local 1439 Worker* worker = nullptr; HWTEST_F() local 1480 Worker* worker = nullptr; HWTEST_F() local 1520 Worker* worker = nullptr; HWTEST_F() local 1603 Worker* worker = nullptr; HWTEST_F() local 1623 Worker* worker = nullptr; HWTEST_F() local 1654 Worker* worker = nullptr; HWTEST_F() local 1708 Worker* worker = nullptr; HWTEST_F() local 1749 Worker* worker = nullptr; HWTEST_F() local 1767 Worker* worker = nullptr; HWTEST_F() local 1794 Worker* worker = nullptr; HWTEST_F() local 1819 Worker* worker = nullptr; HWTEST_F() local 1846 Worker* worker = nullptr; HWTEST_F() local 1877 Worker* worker = nullptr; HWTEST_F() local 1903 Worker* worker = nullptr; HWTEST_F() local 1926 Worker* worker = nullptr; HWTEST_F() local 1967 Worker* worker = nullptr; HWTEST_F() local 2024 Worker* worker = nullptr; HWTEST_F() local 2072 Worker* worker = new Worker(env, nullptr); HWTEST_F() local 2119 Worker* worker = nullptr; HWTEST_F() local 2166 Worker* worker = nullptr; HWTEST_F() local 2183 Worker worker = new Worker(env, nullptr); HWTEST_F() local 2458 Worker worker = nullptr; HWTEST_F() local 2511 Worker* worker = nullptr; HWTEST_F() local 2540 Worker* worker = nullptr; HWTEST_F() local 2568 Worker* worker = nullptr; HWTEST_F() local 2602 Worker* worker = nullptr; HWTEST_F() local 2636 Worker* worker = nullptr; HWTEST_F() local 2668 Worker* worker = nullptr; HWTEST_F() local 2699 Worker* worker = nullptr; HWTEST_F() local 2730 Worker* worker = nullptr; HWTEST_F() local 2758 Worker* worker = nullptr; HWTEST_F() local 2785 Worker* worker = nullptr; HWTEST_F() local 2813 Worker* worker = nullptr; HWTEST_F() local 2847 Worker* worker = nullptr; HWTEST_F() local 2881 Worker* worker = nullptr; HWTEST_F() local 2910 Worker* worker = nullptr; HWTEST_F() local 2943 Worker* worker = nullptr; HWTEST_F() local 2967 Worker* worker = nullptr; HWTEST_F() local 2995 Worker* worker = nullptr; HWTEST_F() local 3027 Worker* worker = nullptr; HWTEST_F() local 3059 Worker* worker = nullptr; HWTEST_F() local 3083 Worker* worker = nullptr; HWTEST_F() local 3105 Worker* worker = nullptr; HWTEST_F() local 3128 Worker* worker = nullptr; HWTEST_F() local 3151 Worker* worker = nullptr; HWTEST_F() local 3176 Worker* worker = nullptr; HWTEST_F() local 3201 Worker* worker = nullptr; HWTEST_F() local 3227 Worker* worker = nullptr; HWTEST_F() local 3258 Worker* worker = nullptr; HWTEST_F() local 3296 Worker* worker = nullptr; HWTEST_F() local 3334 Worker* worker = nullptr; HWTEST_F() local 3372 Worker* worker = nullptr; HWTEST_F() local 3412 Worker* worker = nullptr; HWTEST_F() local 3453 Worker* worker = nullptr; HWTEST_F() local 3504 Worker* worker = nullptr; HWTEST_F() local 3526 Worker* worker = nullptr; HWTEST_F() local 3549 Worker* worker = nullptr; HWTEST_F() local 3572 Worker* worker = nullptr; HWTEST_F() local 3597 Worker* worker = nullptr; HWTEST_F() local 3622 Worker* worker = nullptr; HWTEST_F() local 3654 Worker* worker = nullptr; HWTEST_F() local 3689 Worker* worker = nullptr; HWTEST_F() local 3724 Worker* worker = nullptr; HWTEST_F() local 3761 Worker* worker = nullptr; HWTEST_F() local 3793 Worker* worker = nullptr; HWTEST_F() local 3829 Worker* worker = nullptr; HWTEST_F() local 3858 Worker* worker = nullptr; HWTEST_F() local 3891 Worker* worker = nullptr; HWTEST_F() local 3931 Worker* worker = nullptr; HWTEST_F() local 3972 Worker* worker = nullptr; HWTEST_F() local 4014 Worker* worker = nullptr; HWTEST_F() local 4039 Worker* worker = nullptr; HWTEST_F() local 4074 Worker* worker = nullptr; HWTEST_F() local 4110 Worker* worker = nullptr; HWTEST_F() local 4140 Worker* worker = nullptr; HWTEST_F() local 4169 Worker* worker = nullptr; HWTEST_F() local 4204 Worker* worker = nullptr; HWTEST_F() local 4239 Worker* worker = nullptr; HWTEST_F() local 4254 Worker* worker = nullptr; HWTEST_F() local 4273 Worker* worker = nullptr; HWTEST_F() local 4292 Worker* worker = nullptr; HWTEST_F() local 4311 Worker* worker = nullptr; HWTEST_F() local 4330 Worker* worker = nullptr; HWTEST_F() local 4349 Worker* worker = nullptr; HWTEST_F() local 4368 Worker* worker = nullptr; HWTEST_F() local 4387 Worker* worker = nullptr; HWTEST_F() local 4406 Worker* worker = nullptr; HWTEST_F() local 4425 Worker* worker = nullptr; HWTEST_F() local 4444 Worker* worker = nullptr; HWTEST_F() local 4463 Worker* worker = nullptr; HWTEST_F() local 4482 Worker* worker = nullptr; HWTEST_F() local 4500 Worker* worker = nullptr; HWTEST_F() local 4519 Worker* worker = nullptr; HWTEST_F() local 4538 Worker* worker = nullptr; HWTEST_F() local 4557 Worker* worker = nullptr; HWTEST_F() local 4576 Worker* worker = nullptr; HWTEST_F() local 4595 Worker* worker = nullptr; HWTEST_F() local 4614 Worker* worker = nullptr; HWTEST_F() local 4633 Worker* worker = nullptr; HWTEST_F() local 4652 Worker* worker = nullptr; HWTEST_F() local 4667 Worker *worker = new Worker(env, nullptr); HWTEST_F() local [all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A D	worker.cpp	16 #include "worker.h" 34 Worker::PriorityScope::PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker) in PriorityScope() argument 36 if (taskPriority != worker->priority_) { in PriorityScope() 37 HILOG_DEBUG("taskpool:: reset worker priority to match task priority"); in PriorityScope() 47 worker->priority_ = taskPriority; in PriorityScope() 64 Worker* worker = new Worker(env); in WorkerConstructor() local 65 worker->StartExecuteInThread(); in WorkerConstructor() 66 return worker; in WorkerConstructor() 86 auto worker in ReleaseWorkerHandles() local 148 Worker* worker = reinterpret_cast<Worker>(req->data); HandleDebuggerTask() local 221 auto worker = reinterpret_cast<Worker>(const_cast<void>(data)); ExecuteInThread() local 350 auto worker = reinterpret_cast<Worker>(req->data); TriggerGCCheck() local 384 auto worker = static_cast<Worker>(req->data); PerformTask() local 484 Worker worker = reinterpret_cast<Worker>(task->worker_); NotifyHandleTaskResult() local 520 auto worker = static_cast<Worker>(task->worker_); TaskResultCallback() local [all...]
H A D	task_manager.cpp	39 #include "worker.h" 98 for (auto& worker : workers_) { in ~TaskManager() 99 delete worker; in ~TaskManager() 145 for (auto& worker : workers_) { in GetThreadInfos() 146 if (worker->workerEnv_ == nullptr) { in GetThreadInfos() 149 napi_value tid = NapiHelper::CreateUint32(env, static_cast<uint32_t>(worker->tid_)); in GetThreadInfos() 150 napi_value priority = NapiHelper::CreateUint32(env, static_cast<uint32_t>(worker->priority_)); in GetThreadInfos() 156 std::lock_guard<std::mutex> lock(worker->currentTaskIdMutex_); in GetThreadInfos() 157 for (auto& currentId : worker->currentTaskId_) { in GetThreadInfos() 239 // if the thread num has reached the limit and the idle worker i in CheckForBlockedWorkers() 246 auto worker = iter; CheckForBlockedWorkers() local 410 auto worker = freeList_[i]; TriggerShrink() local 444 auto worker = iter; TriggerShrink() local 468 auto worker = iter; NotifyShrink() local 484 auto worker = (idleWorkers_.begin()); NotifyShrink() local 655 NotifyWorkerIdle(Worker* worker) NotifyWorkerIdle() argument 670 NotifyWorkerCreated(Worker* worker) NotifyWorkerCreated() argument 675 NotifyWorkerAdded(Worker* worker) NotifyWorkerAdded() argument 682 NotifyWorkerRunning(Worker* worker) NotifyWorkerRunning() argument 873 auto worker = Worker::WorkerConstructor(env); CreateWorkers() local 879 RemoveWorker(Worker* worker) RemoveWorker() argument 887 RestoreWorker(Worker* worker) RestoreWorker() argument 973 Worker* worker = static_cast<Worker>(task->worker_); NotifyCallbackExecute() local 1006 auto worker = info->worker; GetMessageQueue() local 1019 auto worker = callbackInfo->worker; GetMessageQueueFromCallbackInfo() local 1272 StoreLongTaskInfo(uint64_t taskId, Worker worker) StoreLongTaskInfo() argument 1294 auto worker = GetLongTaskInfo(taskId); TerminateTask() local [all...]
H A D	worker.h	`132 HILOG_ERROR("taskpool:: Worker loop is nullptr when start worker loop"); in RunLoop() 141 explicit RunningScope(Worker* worker) : worker_(worker) in RunningScope() argument 145 worker->isExecutingLongTask_ = false; in RunningScope() 160 PriorityScope(Worker* worker, Priority taskPriority); 211 std::atomic<bool> idleState_ = true; // true means the worker is idle 215 std::atomic<bool> hasExecuted_ = false; // false means this worker hasn't execute any tasks`
H A D	task_manager.h	`34 #include "worker.h" 71 // for worker state 72 void NotifyWorkerIdle(Worker* worker); 73 void NotifyWorkerCreated(Worker* worker); 74 void NotifyWorkerRunning(Worker* worker); 75 void RemoveWorker(Worker* worker); 76 void RestoreWorker(Worker* worker); 98 // for countTrace for worker 130 void StoreLongTaskInfo(uint64_t taskId, Worker* worker); 160 void NotifyWorkerAdded(Worker* worker); [all...]`
H A D	task.h	`139 bool UpdateTask(uint64_t startTime, void* worker); 213 : hostEnv(env), refCount(count), callbackRef(ref), task(task), onCallbackSignal(nullptr), worker(nullptr) {} in CallbackInfo() 236 Worker* worker; member`
H A D	task.cpp	`25 #include "worker.h" 1077 bool Task::UpdateTask(uint64_t startTime, void* worker) in UpdateTask() argument 1086 worker_ = worker; in UpdateTask()`
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A D	worker.cpp	16 #include "worker.h" 82 // for worker.ThreadWorker in InitWorker() 89 // for worker.Worker in InitWorker() 96 // for worker.LimitedWorker in InitWorker() 108 Worker* worker = nullptr; in InitPort() local 113 worker = item; in InitPort() 120 worker = item; in InitPort() 127 if (worker == nullptr) { in InitPort() 128 ErrorHelper::ThrowError(env, ErrorHelper::ERR_WORKER_NOT_RUNNING, "worker is null when InitWorker"); in InitPort() 133 DECLARE_NAPI_FUNCTION_WITH_DATA("postMessage", PostMessageToHost, worker), in InitPort() 233 Worker* worker = nullptr; Constructor() local 304 Worker* worker = reinterpret_cast<Worker>(data); WorkerDestructor() local 330 Worker worker = reinterpret_cast<Worker>(data); HostEnvCleanCallback() local 428 Worker worker = nullptr; CommonPostMessage() local 465 Worker* worker = nullptr; Terminate() local 518 Worker* worker = nullptr; RegisterGlobalCallObject() local 542 Worker* worker = nullptr; UnregisterGlobalCallObject() local 605 Worker* worker = nullptr; AddListener() local 650 Worker* worker = nullptr; RemoveListener() local 709 Worker* worker = nullptr; DispatchEvent() local 749 Worker* worker = nullptr; RemoveAllListener() local 765 Worker* worker = nullptr; CancelTask() local 805 Worker* worker = nullptr; CommonPostMessageToHost() local 855 Worker* worker = nullptr; GlobalCall() local 984 Worker* worker = nullptr; CloseWorker() local 997 Worker* worker = nullptr; ParentPortCancelTask() local 1026 Worker* worker = nullptr; ParentPortAddEventListener() local 1066 Worker* worker = nullptr; ParentPortDispatchEvent() local 1124 Worker* worker = nullptr; ParentPortRemoveEventListener() local 1162 Worker* worker = nullptr; ParentPortRemoveAllListener() local 1269 auto worker = reinterpret_cast<Worker>(const_cast<void>(data)); ExecuteInThread() local 1397 Worker* worker = static_cast<Worker>(req->data); HostOnMessage() local 1469 Worker worker = static_cast<Worker>(req->data); HostOnGlobalCall() local 1685 Worker worker = static_cast<Worker>(req->data); HostOnError() local 1912 IsValidWorker(Worker worker) IsValidWorker() argument 1925 Worker* worker = static_cast<Worker>(req->data); WorkerOnMessage() local 2169 Worker worker = nullptr; ReleaseHostThreadContent() local 2373 Worker* worker = DereferenceHelp::DereferenceOf(&Worker::debuggerOnPostTaskSignal_, req); HandleDebuggerTask() local [all...]
H A D	worker.h	96 * Creates a worker instance. 99 * @param thisVar URL of the script to be executed by the worker. 123 * The worker thread receives the information. 132 * @param data The worker pointer. 185 * Terminates the worker thread to stop the worker from receiving messages. 193 * Close the worker. 201 * Adds an event listener to the worker. 209 * Adds an event listener to the worker and removes the event listener automatically after it is invoked once. 217 * Removes an event listener to the worker [all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A D	test.cpp	27 #include "worker.h" 197 Worker* worker = reinterpret_cast<Worker>(WorkerConstructor(env)); in CheckForBlockedWorkers() local 198 worker->workerEnv_ = nullptr; in CheckForBlockedWorkers() 201 taskManager.workers_.insert(worker); in CheckForBlockedWorkers() 204 worker->workerEnv_ = env; in CheckForBlockedWorkers() 205 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers() 206 worker->startTime_ = ConcurrentHelper::GetMilliseconds() - MAX_TIMEOUT_TIME; in CheckForBlockedWorkers() 207 worker->idleState_ = true; in CheckForBlockedWorkers() 210 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers() 211 worker in CheckForBlockedWorkers() 235 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); TriggerShrink() local 311 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); TryExpand() local 367 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); NotifyWorkerIdle() local 390 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); EnqueueTaskId() local 422 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); RestoreWorker() local 479 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); NotifyDependencyTaskInfo() local 740 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); ReleaseWorkerHandles() local 760 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); DebuggerOnPostTask() local 796 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); PerformTask() local 830 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); NotifyHandleTaskResult() local 849 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); TaskResultCallback() local 882 Worker worker = reinterpret_cast<Worker>(WorkerConstructor(env)); HandleFunctionException() local 903 Worker worker = Worker::WorkerConstructor(env); WorkerConstructor() local 912 Worker* worker = reinterpret_cast<Worker*>(handle->data); GetWorkerTid() local [all...]
H A D	test_taskpool.cpp	29 #include "worker.h" 131 Worker* worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); in HWTEST_F() local 132 ASSERT_NE(worker, nullptr); in HWTEST_F() 147 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); in HWTEST_F() local 148 ASSERT_NE(worker, nullptr); in HWTEST_F() 527 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); in HWTEST_F() local 530 taskManager.NotifyWorkerIdle(worker); in HWTEST_F() 531 ASSERT_NE(worker, nullptr); in HWTEST_F() 532 taskManager.NotifyWorkerCreated(worker); in HWTEST_F() 533 ASSERT_NE(worker, nullpt in HWTEST_F() 968 auto worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 997 auto worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 2046 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 2074 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 2108 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 2152 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 3939 Worker worker = reinterpret_cast<Worker>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local 4530 Worker worker = reinterpret_cast<Worker*>(NativeEngineTest::WorkerConstructor(env)); HWTEST_F() local [all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A D	worker.rs	`19 /// worker struct info and method 32 pub(crate) worker: Arc<Worker>, 38 let worker_ref = &self.worker; in run() 43 let mut yielded = self.worker.yielded.borrow_mut(); 55 self.worker.release(); in release() 77 /// Gets the worker context of the current thread 90 /// Runs the worker thread 91 pub(crate) fn run_worker(worker: Arc<Worker>, handle: Arc<Handle>) { 92 let mut cur_context = WorkerContext { worker }; 104 // store the worker t [all...]`
H A D	async_pool.rs	26 use super::worker::{get_current_ctx, run_worker, Worker}; 27 use super::{worker, Schedule}; 30 use crate::executor::worker::WorkerContext; 131 // index is bounded by total worker num 141 pub(crate) fn turn_to_sleep(&self, worker_inner: &mut worker::Inner, worker_index: usize) { 161 // this index is bounded by total worker num 171 // this index is bounded by total worker num 181 // The returned value indicates whether or not to wake up another worker 184 if !std::ptr::eq(&self.global, &worker_ctx.worker.scheduler.global) { in enqueue_under_ctx() 190 let mut lifo_slot = worker_ctx.worker in enqueue_under_ctx() [all...]
H A D	mod.rs	`33 use crate::executor::worker::WorkerHandle; 43 pub(crate) mod worker; 289 worker::CURRENT_HANDLE.with(\|ctx\| { in block_on_inner() 301 let cur_context = worker::WorkerHandle { in block_on_inner() 305 worker::CURRENT_HANDLE.with(\|ctx\| { in block_on_inner() 316 // otherwise the worker's CURRENT_WORKER can not be set under MultiThread. in block_on_inner() 317 worker::CURRENT_HANDLE.with(\|ctx\| { in block_on_inner()`
H A D	driver_handle.rs	`18 use crate::executor::worker::get_current_handle;`
H A D	current_thread.rs	`477 crate::executor::worker::CURRENT_WORKER.with(\|ctx\| { in ut_current_thread_run_queue()`
/commonlibrary/ets_utils/js_sys_module/process/
H A D	js_childprocess.h	`26 napi_async_work worker {nullptr}; 32 napi_async_work worker {nullptr}; 43 napi_async_work worker {nullptr};`
H A D	js_childprocess.cpp	104 napi_delete_async_work(env, optionsInfo->worker); in Spawn() 108 reinterpret_cast<void>(optionsInfo_), &optionsInfo_->worker); in Spawn() 109 napi_queue_async_work_with_qos(env, optionsInfo_->worker, napi_qos_user_initiated); in Spawn() 163 NAPI_CALL(env, napi_delete_async_work(env, stdOutInfo_->worker)); in GetOutput() 191 NAPI_CALL(env, napi_delete_async_work(env, stdErrInfo_->worker)); in GetErrorOutput() 260 reinterpret_cast<void>(stdOutInfo_), &stdOutInfo_->worker); in CreateWorker() 261 napi_queue_async_work_with_qos(env, stdOutInfo_->worker, napi_qos_user_initiated); in CreateWorker() 275 reinterpret_cast<void*>(stdErrInfo_), &stdErrInfo_->worker); in CreateWorker() 276 napi_queue_async_work_with_qos(env, stdErrInfo_->worker, napi_qos_user_initiated); in CreateWorker() 309 napi_delete_async_work(env, stdOutInfo->worker); in EndStdOut() [all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A D	yield_now.rs	`20 use crate::executor::worker; 48 let ctx = worker::get_current_ctx(); in poll() 50 // Under worker context, we push the waker into the yielded list owned by the in poll() 51 // worker to avoid waking the waker immediately. This is because in poll() 52 // waking the waker in a worker context will put the task in the in poll() 55 let mut yielded = ctx.worker.yielded.borrow_mut(); in poll()`
/commonlibrary/ets_utils/js_util_module/util/
H A D	js_base64.cpp	413 reinterpret_cast<void>(stdEncodeInfo_), &stdEncodeInfo_->worker); in CreateEncodePromise() 414 napi_queue_async_work_with_qos(env, stdEncodeInfo_->worker, napi_qos_user_initiated); in CreateEncodePromise() 427 reinterpret_cast<void>(stdEncodeInfo_), &stdEncodeInfo_->worker); in CreateEncodeToStringPromise() 428 napi_queue_async_work_with_qos(env, stdEncodeInfo_->worker, napi_qos_user_initiated); in CreateEncodeToStringPromise() 526 napi_delete_async_work(env, stdEncodeInfo->worker); in EndStdEncode() 532 napi_delete_async_work(env, stdEncodeInfo->worker); in EndStdEncode() 557 napi_delete_async_work(env, stdEncodeInfo->worker); in EndStdEncodeToString() 619 reinterpret_cast<void*>(stdDecodeInfo_), &stdDecodeInfo_->worker); in CreateDecodePromise() 620 napi_queue_async_work_with_qos(env, stdDecodeInfo_->worker, napi_qos_user_initiated); in CreateDecodePromise() 760 napi_delete_async_work(env, stdDecodeInfo->worker); in EndStdDecode() [all...]
H A D	js_base64.h	`43 napi_async_work worker = nullptr; member 55 napi_async_work worker = nullptr; member`
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/
H A D	multi_thread_builder.rs	88 /// Sets the maximum worker number for a specific qos group. 90 /// If a worker number has already been set for a qos, calling the method 94 /// The accepted worker number range for each qos is [1, 20]. If 0 is passed 95 /// in, then the maximum worker number will be set to 1. If a number 96 /// greater than 20 is passed in, then the maximum worker number will be 99 let worker = match num { in max_worker_num_by_qos() 104 self.thread_num_by_qos.insert(qos, worker); in max_worker_num_by_qos() 108 /// Sets the name prefix for all worker threads. 114 /// Sets the number of core worker threads. 132 /// Sets the core affinity of the worker thread [all...]
/commonlibrary/ets_utils/js_api_module/buffer/
H A D	native_module_buffer.cpp	1036 napi_async_work worker = nullptr; member 1048 napi_delete_async_work(env, promiseInfo->worker); in CopiedBlobToString() 1059 napi_delete_async_work(env, promiseInfo->worker); in CopiedBlobToArrayBuffer() 1085 reinterpret_cast<void >(promiseInfo), &promiseInfo->worker); in ArrayBufferAsync() 1086 napi_queue_async_work_with_qos(env, promiseInfo->worker, napi_qos_user_initiated); in ArrayBufferAsync() 1109 reinterpret_cast<void >(promiseInfo), &promiseInfo->worker); in TextAsync() 1110 napi_queue_async_work_with_qos(env, promiseInfo->worker, napi_qos_user_initiated); in TextAsync()

Completed in 251 milliseconds