WorkerState (reference) in projects: commonlibrary - OpenGrok search results

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:WorkerState (Results 1 - 4 of 4) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A D	worker.h	`43 enum class WorkerState { IDLE, RUNNING, BLOCKED }; class 103 state_ = WorkerState::RUNNING; in NotifyTaskRunning() 176 bool UpdateWorkerState(WorkerState expect, WorkerState desired); 214 std::atomic<WorkerState> state_ {WorkerState::IDLE};`
H A D	worker.cpp	`306 if (state_ == WorkerState::BLOCKED) { in ReleaseWorkerThreadContent() 371 UpdateWorkerState(WorkerState::RUNNING, WorkerState::IDLE); in NotifyTaskFinished() 376 bool Worker::UpdateWorkerState(WorkerState expect, WorkerState desired) in UpdateWorkerState() 583 if (LIKELY(state_ != WorkerState::BLOCKED)) { in UpdateExecutedInfo()`
H A D	task_manager.cpp	249 if ((worker->state_ == WorkerState::IDLE) \|\| (worker->IsExecutingLongTask()) \|\| in CheckForBlockedWorkers() 251 !worker->UpdateWorkerState(WorkerState::RUNNING, WorkerState::BLOCKED)) { in CheckForBlockedWorkers() 261 worker->UpdateWorkerState(WorkerState::BLOCKED, WorkerState::IDLE); in CheckForBlockedWorkers() 263 worker->UpdateWorkerState(WorkerState::BLOCKED, WorkerState::RUNNING); in CheckForBlockedWorkers() 411 if (worker->state_ != WorkerState::IDLE \|\| worker->HasLongTask()) { in TriggerShrink() 659 if (worker->state_ == WorkerState::BLOCKED) { in NotifyWorkerIdle() 798 if (worker->state_ == WorkerState in IsChooseIdle() [all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A D	test.cpp	205 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers() 210 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers() 216 worker->state_ = WorkerState::RUNNING; in CheckForBlockedWorkers() 240 worker->state_ = WorkerState::RUNNING; in TriggerShrink() 247 worker->state_ = WorkerState::IDLE; in TriggerShrink() 255 worker->state_ = WorkerState::IDLE; in TriggerShrink() 371 worker->state_ = WorkerState::BLOCKED; in NotifyWorkerIdle() 373 worker->state_ = WorkerState::IDLE; in NotifyWorkerIdle() 391 worker->state_ = WorkerState::RUNNING; in EnqueueTaskId() 424 worker->state_ = WorkerState in RestoreWorker() [all...]

Completed in 5 milliseconds