Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 25 of 215) sorted by relevance

123456789

/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dcpu_worker.cpp164 if (worker->tick % worker->global_interval == 0) { in GetTask()
173 worker->ops.NotifyTaskPicked(worker); in GetTask()
189 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); in GetTask()
191 worker->ops.NotifyTaskPicked(worker); in GetTask()
200 PollerRet ret = worker->ops.TryPoll(worker, timeout); in TryPoll()
228 worker->ops.WorkerPrepare(worker); in Dispatch()
233 worker->ops.WorkerLooper(worker); in Dispatch()
235 worker->ops.WorkerRetired(worker); in Dispatch()
248 worker->ops.TryPoll(worker, 0); in WorkerLooperDefault()
268 worker->ops.NotifyTaskPicked(worker); in WorkerLooperDefault()
[all …]
H A Dcpu_worker.h53 static void Run(CPUEUTask* task, CoRoutineEnv* coRoutineEnv, CPUWorker* worker);
56 static void* WrapDispatch(void* worker);
57 static void Dispatch(CPUWorker* worker);
59 static void RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker);
60 …static void RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker, ExecuteCtx* ctx, CoRoutineEn…
61 static void RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker);
62 static void* GetTask(CPUWorker* worker);
63 static PollerRet TryPoll(CPUWorker* worker, int timeout);
64 static bool LocalEmpty(CPUWorker* worker);
/ohos5.0/docs/zh-cn/application-dev/arkts-utils/
H A Dworker-introduction.md10 ![worker](figures/worker.png)
70 const worker1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/worker.ets');
72 const worker2: worker.Worker = new worker.Worker('entry/ets/workers/worker.ets');
91 const workerStage1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/worker.ets');
104 // worker线程文件所在路径： "hsp/src/main/ets/workers/worker.ets"
105 const workerStage3: worker.ThreadWorker = new worker.ThreadWorker('hsp/ets/workers/worker.ets');
125 const workerStage4: worker.ThreadWorker = new worker.ThreadWorker('@har/ets/workers/worker.ets');
130 const workerStage5: worker.ThreadWorker = new worker.ThreadWorker('../../workers/worker.ets');
144 const workerFA1: worker.ThreadWorker = new worker.ThreadWorker("workers/worker.ets", {name:"first w…
147 const workerFA2: worker.ThreadWorker = new worker.ThreadWorker("../workers/worker.ets");
[all …]
/ohos5.0/docs/en/application-dev/arkts-utils/
H A Dworker-introduction.md10 ![worker](figures/worker.png)
70 const worker1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/worker.ets');
72 const worker2: worker.Worker = new worker.Worker('entry/ets/workers/worker.ets');
91 const workerStage1: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/worker.ets');
105 const workerStage3: worker.ThreadWorker = new worker.ThreadWorker('hsp/ets/workers/worker.ets');
125 const workerStage4: worker.ThreadWorker = new worker.ThreadWorker('@har/ets/workers/worker.ets');
130 const workerStage5: worker.ThreadWorker = new worker.ThreadWorker('../../workers/worker.ets');
144 const workerFA1: worker.ThreadWorker = new worker.ThreadWorker("workers/worker.ets", {name:"first w…
147 const workerFA2: worker.ThreadWorker = new worker.ThreadWorker("../workers/worker.ets");
150 const workerFA3: worker.ThreadWorker = new worker.ThreadWorker("ThreadFile/workers/worker.ets");
[all …]
H A Dcpu-intensive-task-development.md86 import { worker } from '@kit.ArkTS';
88 …const workerInstance: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/MyWorker.ts…
91 …worker.md#onmessage9) to receive messages from the worker thread, and call [postMessage()](../refe…
98 // Receive the result from the worker thread.
111 // Send a training message to the worker thread.
139 // onmessage logic of the worker thread.
162 6. After the task is completed in the worker thread, destroy the worker thread. The worker thread c…
173 …inate()](../reference/apis-arkts/js-apis-worker.md#terminate9) to destroy the worker thread and st…
176 // Destroy the worker thread.
180 …d 2: In the worker thread, call [close()](../reference/apis-arkts/js-apis-worker.md#close9) to des…
[all …]
H A Dworker-communicates-with-mainthread.md4 …worker-introduction.md) may execute multiple tasks. The execution duration or returned result of e…
7 The following uses an example in which the worker responds to the "hello world" request for descrip…
14 import { ErrorEvent, MessageEvents, ThreadWorkerGlobalScope, worker } from '@kit.ArkTS';
16 const workerPort: ThreadWorkerGlobalScope = worker.workerPort;
17 // The worker receives the message from the host thread and performs corresponding processing.
25 …worker object is created in the host thread. When the button is clicked, the postmessage function …
29 import { worker } from '@kit.ArkTS';
43 let ss = new worker.ThreadWorker("entry/ets/workers/Worker.ets");
50 Receive messages sent by the worker thread.
54 console.info("worker:: res is " + res);
[all …]
/ohos5.0/docs/zh-cn/application-dev/reference/apis-arkts/
H A Djs-apis-worker-sys.md1 # @ohos.worker (启动一个Worker)(系统接口)
9 Worker使用过程中的相关注意点请查[Worker注意事项](../../arkts-utils/worker-introduction.md#worker注意事项)
15 > - 当前页面仅包含本模块的系统接口，其他公开接口参见[@ohos.worker (启动一个Worker)](js-apis-worker.md)。
20 import { worker } from '@kit.ArkTS';
68 // 场景1： worker文件所在路径："entry/src/main/ets/workers/worker.ets"
69 const workerStageModel01 = new worker.RestrictedWorker('entry/ets/workers/worker.ets', {name:"first…
71 // 场景2： worker文件所在路径："phone/src/main/ets/ThreadFile/workers/worker.ets"
72 const workerStageModel02 = new worker.RestrictedWorker('phone/ets/ThreadFile/workers/worker.ets');
76 // 受限worker线程文件
84 console.info("worker:: This is worker thread.")
[all …]
H A Djs-apis-worker.md1 # @ohos.worker (启动一个Worker)
83 // 场景1： worker文件所在路径："entry/src/main/ets/workers/worker.ets"
553 // worker线程：
1077 // worker.ets
1128 // worker.ets
1250 // worker.ets
1302 // worker.ets
1343 // worker.ets
1383 // worker.ets
1473 // worker.ets
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dworker.cpp34 Worker::PriorityScope::PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker) in PriorityScope() argument
66 return worker; in WorkerConstructor()
138 if (worker == nullptr) { in HandleDebuggerTask()
211 napi_create_runtime(worker->hostEnv_, &worker->workerEnv_); in ExecuteInThread()
243 worker->InitFfrtInfo(); in ExecuteInThread()
246 worker->RunLoop(); in ExecuteInThread()
253 delete worker; in ExecuteInThread()
254 worker = nullptr; in ExecuteInThread()
377 worker->NotifyIdle(); in PerformTask()
392 worker->NotifyTaskBegin(); in PerformTask()
[all …]
H A Dtask_manager.cpp99 delete worker; in ~TaskManager()
246 auto worker = *iter; in CheckForBlockedWorkers() local
249 if ((worker->state_ == WorkerState::IDLE) || (worker->IsExecutingLongTask()) || in CheckForBlockedWorkers()
410 if (worker->state_ != WorkerState::IDLE || worker->HasLongTask()) { in TriggerShrink()
483 if (worker == nullptr || worker->clearWorkerSignal_ == nullptr) { in NotifyShrink()
687 NotifyWorkerIdle(worker); in NotifyWorkerCreated()
693 workers_.insert(worker); in NotifyWorkerAdded()
900 workers_.erase(worker); in RemoveWorker()
999 callbackInfo->worker = worker; in NotifyCallbackExecute()
1028 auto worker = info->worker; in GetMessageQueue() local
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp152 worker->workerOnMessageSignal_->data = worker; in WorkerThreadFunction()
153 worker->Loop(); in WorkerThreadFunction()
165 worker->hostOnMessageSignal_->data = worker; in InitHostHandle()
190 worker->workerOnMessageSignal_->data = worker; in SetCloseWorkerProp()
344 req->data = worker;
374 req->data = worker;
770 req->data = worker;
1074 req->data = worker;
1122 req->data = worker;
1394 delete worker;
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.cpp467 if (worker == nullptr || worker->IsTerminated() || worker->IsTerminating()) { in CommonPostMessage()
514 if (worker->IsTerminated() || worker->IsTerminating()) { in Terminate()
799 if (worker->IsTerminated() || worker->IsTerminating()) { in CancelTask()
1027 if (worker->IsTerminated() || worker->IsTerminating()) { in ParentPortCancelTask()
1064 if (worker == nullptr || !worker->IsNotTerminate()) { in ParentPortAddEventListener()
1108 if (worker == nullptr || !worker->IsNotTerminate()) { in ParentPortDispatchEvent()
1160 if (worker == nullptr || !worker->IsNotTerminate()) { in ParentPortRemoveEventListener()
1187 if (worker == nullptr || !worker->IsNotTerminate()) { in ParentPortRemoveAllListener()
1296 if (worker->HostIsStop() || worker->isHostEnvExited_) { in ExecuteInThread()
1337 worker->workerOnMessageSignal_->data = worker; in ExecuteInThread()
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp204 worker->workerEnv_ = env; in CheckForBlockedWorkers()
236 worker->workerEnv_ = env; in TriggerShrink()
481 task->worker_ = worker; in NotifyDependencyTaskInfo()
754 req->data = worker; in ReleaseWorkerHandles()
774 req->data = worker; in DebuggerOnPostTask()
787 worker->hostEnv_ = env; in DebuggerOnPostTask()
820 req->data = worker; in PerformTask()
840 task->worker_ = worker; in NotifyHandleTaskResult()
855 task->worker_ = worker; in TaskResultCallback()
908 return worker; in WorkerConstructor()
[all …]
/ohos5.0/docs/zh-cn/release-notes/api-diff/monthly-202210/
H A Djs-apidiff-compiler-and-runtime.md80 |新增|NA|模块名: ohos.worker<br>类名: WorkerEventListener|@ohos.worker.d.ts|
82 |新增|NA|模块名: ohos.worker<br>类名: WorkerEventTarget|@ohos.worker.d.ts|
87 |新增|NA|模块名: ohos.worker<br>类名: GlobalScope|@ohos.worker.d.ts|
88 |新增|NA|模块名: ohos.worker<br>类名: GlobalScope<br>方法名 or 属性名：name|@ohos.worker.d.ts|
90 |新增|NA|模块名: ohos.worker<br>类名: GlobalScope<br>方法名 or 属性名：self|@ohos.worker.d.ts|
94 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorkerGlobalScope|@ohos.worker.d.ts|
100 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker|@ohos.worker.d.ts|
108 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker<br>方法名 or 属性名：on|@ohos.worker.d.ts|
109 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker<br>方法名 or 属性名：once|@ohos.worker.d.ts|
110 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker<br>方法名 or 属性名：off|@ohos.worker.d.ts|
[all …]
/ohos5.0/docs/zh-cn/release-notes/api-diff/v3.2-beta4/
H A Djs-apidiff-compiler-and-runtime.md88 |新增|NA|模块名: ohos.worker<br>类名: MessageEvents|@ohos.worker.d.ts|
90 |新增|NA|模块名: ohos.worker<br>类名: WorkerEventListener|@ohos.worker.d.ts|
92 |新增|NA|模块名: ohos.worker<br>类名: WorkerEventTarget|@ohos.worker.d.ts|
97 |新增|NA|模块名: ohos.worker<br>类名: GlobalScope|@ohos.worker.d.ts|
98 |新增|NA|模块名: ohos.worker<br>类名: GlobalScope<br>方法名 or 属性名：name|@ohos.worker.d.ts|
100 |新增|NA|模块名: ohos.worker<br>类名: GlobalScope<br>方法名 or 属性名：self|@ohos.worker.d.ts|
101 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorkerGlobalScope|@ohos.worker.d.ts|
107 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker|@ohos.worker.d.ts|
115 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker<br>方法名 or 属性名：on|@ohos.worker.d.ts|
117 |新增|NA|模块名: ohos.worker<br>类名: ThreadWorker<br>方法名 or 属性名：off|@ohos.worker.d.ts|
[all …]
/ohos5.0/docs/zh-cn/application-dev/media/camera/
H A Dcamera-worker.md9 1. 创建worker线程文件，配置worker。
25 context: Context; // 注意worker线程中无法使用getContext()直接获取宿主线程context，需要通过消息从宿主线程通信到worker线程使用。
33 // 在worker线程中收到宿主线程初始化相机的消息
35 // 在worker线程中初始化相机
38 // 在worker线程中收到宿主线程释放相机的消息
40 // 在worker线程中释放相机
169 // 创建ThreadWorker对象获取worker实例
174 // 通过worker实例向worker线程发送消息初始化相机
184 // 通过worker实例向worker线程发送消息销毁相机
237 不使用worker：
[all …]
/ohos5.0/docs/en/application-dev/reference/apis-arkts/
H A Djs-apis-worker-sys.md1 # @ohos.worker (Starting the Worker) (System API)
9 …orker, see [Precautions for Worker](../../arkts-utils/worker-introduction.md#precautions-for-worke…
20 import { worker } from '@kit.ArkTS';
56 | 10200007 | The worker file patch is invalid path. |
65 import { worker } from '@kit.ArkTS';
70 const workerStageModel01 = new worker.RestrictedWorker('entry/ets/workers/worker.ets', {name:"first…
73 const workerStageModel02 = new worker.RestrictedWorker('phone/ets/ThreadFile/workers/worker.ets');
78 import { worker, MessageEvents } from '@kit.ArkTS';
82 const workerPort = worker.workerPort;
85 console.info("worker:: This is worker thread.")
[all …]
H A Djs-apis-worker.md1078 // worker.ets
1129 // worker.ets
1251 // worker.ets
1303 // worker.ets
1344 // worker.ets
1384 // worker.ets
1474 // worker.ets
2022 // worker.ets
2065 // worker.ets
2094 // worker.ets
[all …]
/ohos5.0/docs/zh-cn/application-dev/reference/apis-arkui/arkui-ts/
H A Dts-container-isolated-component-sys.md29 2、主线程与受限worker线程之间布局渲染是异步处理，布局变化、旋转等导致的页面变化存在不同步现象。
31 3、主线程与受限worker线程之间事件传递是异步处理，不支持线程之间的事件冒泡，线程之间的UI交互存在事件冲突现象。
37 2、独立Abc运行在受限worker可保证相对安全，独立Abc内容不影响主线程。
47 创建IsolatedComponent组件，用于显示受限worker运行的Abc。
63 | worker | [RestrictedWorker](../../apis-arkts/js-apis-worker-sys.md#restrictedworker11) | 是 …
72 将事件经过坐标转换后异步传递给受限worker线程处理。
96 - 受限worker脚本`ets/workers/OhCardWorker.ets`的内容如下：
109 import { worker } from '@kit.ArkTS';
140 // 受限worker
141 …private worker ?: worker.RestrictedWorker = new worker.RestrictedWorker("entry/ets/workers/OhCardW…
[all …]
/ohos5.0/base/security/device_security_level/baselib/utils/src/
H A Dutils_work_queue.c52 Worker *worker = NULL; in WorkQueueThread() local
69 RemoveListNode(&worker->linkNode); in WorkQueueThread()
73 worker->process(worker->dataBuff, worker->dataLen); in WorkQueueThread()
74 FREE(worker); in WorkQueueThread()
81 RemoveListNode(&worker->linkNode); in WorkQueueThread()
83 FREE(worker); in WorkQueueThread()
226 if (worker == NULL) { in QueueWork()
231 InitListHead(&worker->linkNode); in QueueWork()
232 worker->dataLen = length; in QueueWork()
233 worker->dataBuff = data; in QueueWork()
[all …]
/ohos5.0/docs/en/application-dev/media/camera/
H A Dcamera-worker.md9 1. Create a worker thread file and configure the worker.
19 const workerPort: ThreadWorkerGlobalScope = worker.workerPort;
31 console.info(`worker onmessage type:${messageInfo.type}`)
35 // Initialize the camera in the worker thread.
39 console.info('worker releaseCamera.');
40 // Release the camera in the worker thread.
160 import { worker } from '@kit.ArkTS';
170 …private workerInstance: worker.ThreadWorker = new worker.ThreadWorker('entry/ets/workers/CameraWor…
174 … // Send a message to the worker thread through the worker instance to initialize the camera.
184 // Send a message to the worker thread through the worker instance to destroy the camera.
[all …]
/ohos5.0/foundation/ai/ai_engine/services/server/plugin/asr/keyword_spotting/source/
H A Dkws_plugin.cpp47 worker.typeConverter = std::make_shared<TypeConverter>(); in InitWorkplace()
49 if (worker.slideProcessor == nullptr || in InitWorkplace()
50 worker.typeConverter == nullptr || in InitWorkplace()
51 worker.normProcessor == nullptr) { in InitWorkplace()
119 KWSWorkplace worker = { in Prepare() local
125 if (InitComponents(worker) != RETCODE_SUCCESS) { in Prepare()
129 handles_.emplace(handle, worker); in Prepare()
331 int32_t KWSPlugin::InitComponents(KWSWorkplace &worker) in InitComponents() argument
348 worker.slideProcessor = nullptr; in InitComponents()
349 worker.typeConverter = nullptr; in InitComponents()
[all …]
/ohos5.0/docs/en/release-notes/api-diff/v3.2-beta4/
H A Djs-apidiff-compiler-and-runtime.md88 |Added|NA|Module name: ohos.worker<br>Class name: MessageEvents|@ohos.worker.d.ts|
90 |Added|NA|Module name: ohos.worker<br>Class name: WorkerEventListener|@ohos.worker.d.ts|
92 |Added|NA|Module name: ohos.worker<br>Class name: WorkerEventTarget|@ohos.worker.d.ts|
97 |Added|NA|Module name: ohos.worker<br>Class name: GlobalScope|@ohos.worker.d.ts|
98 |Added|NA|Module name: ohos.worker<br>Class name: GlobalScope<br>Method or attribute name: name|@oh…
100 |Added|NA|Module name: ohos.worker<br>Class name: GlobalScope<br>Method or attribute name: self|@oh…
101 |Added|NA|Module name: ohos.worker<br>Class name: ThreadWorkerGlobalScope|@ohos.worker.d.ts|
107 |Added|NA|Module name: ohos.worker<br>Class name: ThreadWorker|@ohos.worker.d.ts|
115 |Added|NA|Module name: ohos.worker<br>Class name: ThreadWorker<br>Method or attribute name: on|@oho…
117 |Added|NA|Module name: ohos.worker<br>Class name: ThreadWorker<br>Method or attribute name: off|@oh…
[all …]
/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_service.c172 return SendResponseMsg(worker, msg, -1); in HandleParamSet()
175 srcLabel.sockFd = LE_GetSocketFd(worker); in HandleParamSet()
181 return SendResponseMsg(worker, msg, ret); in HandleParamSet()
255 extData.stream = worker; in HandleParamWaitAdd()
292 g_paramService.watcherTask = worker; in HandleParamWatcherAdd()
296 extData.stream = worker; in HandleParamWatcherAdd()
304 return SendResponseMsg(worker, msg, 0); in HandleParamWatcherAdd()
312 return SendResponseMsg(worker, msg, 0); in HandleParamWatcherDel()
330 return SendResponseMsg(worker, msg, 0); in HandleParamSave()
340 ret = HandleParamSet(worker, msg); in ProcessMessage()
[all …]
/ohos5.0/docs/zh-cn/release-notes/api-diff/v3.2-beta5/
H A Djs-apidiff-compiler-and-runtime.md18 …worker<br>方法 or 属性：const parentPort: DedicatedWorkerGlobalScope;<br>废弃版本：N/A|类名：worker<br>方法 or 属性…
20 …worker<br>方法 or 属性：const parentPort: DedicatedWorkerGlobalScope;<br>起始版本：N/A|类名：worker<br>方法 or 属性…
21 …worker<br>方法 or 属性：const workerPort: ThreadWorkerGlobalScope;<br>起始版本：N/A|类名：worker<br>方法 or 属性：co…
22 …属性：onmessage?: (this: DedicatedWorkerGlobalScope, ev: MessageEvent) => void;<br>|@ohos.worker.d.ts|
23 …messageerror?: (this: DedicatedWorkerGlobalScope, ev: MessageEvent) => void;<br>|@ohos.worker.d.ts|
24 …> void;<br>|类名：Worker<br>方法 or 属性：onmessage?: (event: MessageEvent) => void;<br>|@ohos.worker.d.ts|
25 …d;<br>|类名：Worker<br>方法 or 属性：onmessageerror?: (event: MessageEvent) => void;<br>|@ohos.worker.d.ts|

123456789