| /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()
|