Files
js_api_module/worker/worker_runner.h
T
y00576111 1459ce5be1 fixed 7748571 from https://gitee.com/wang_zhaoyong/js_worker_module/pulls/52
add Timer Interface for worker

execute polling operation and delay operation in the worker Without
waking up the system,add timer related interfaces,
setTimeout, setinterval, cleartimeout, clearinterval in worker
initialize

issue: https://gitee.com/openharmony/js_worker_module/issues/I51DAA

Signed-off-by: y00576111 <yaojian16@huawei.com>
Change-Id: I7089854c7f557c3f1d9f906854a2dad682e68400
2022-04-15 08:15:51 +00:00

63 lines
1.9 KiB
C++

/*
* Copyright (c) 2022 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef JS_WORKER_MODULE_WORKER_WORKER_RUNNER_H_
#define JS_WORKER_MODULE_WORKER_WORKER_RUNNER_H_
#include <functional>
#include "native_engine/native_engine.h"
#include "base/compileruntime/js_worker_module/worker/thread.h"
namespace CompilerRuntime::WorkerModule {
struct WorkerStartCallback {
using CallbackFunction = std::function<void(void*)>;
explicit WorkerStartCallback(CallbackFunction function = nullptr, void* dataArgs = nullptr)
: callback(function), data(dataArgs)
{}
CallbackFunction callback;
void* data;
};
class WorkerRunner {
public:
// real thread execute
class WorkerInnerRunner : public Thread {
public:
explicit WorkerInnerRunner(const WorkerRunner* runner);
~WorkerInnerRunner() = default;
void Run() override;
private:
const WorkerRunner* runner_;
};
explicit WorkerRunner(WorkerStartCallback callback);
~WorkerRunner();
bool Execute();
void Run() const;
void Stop();
private:
WorkerInnerRunner* workerInnerRunner_ {nullptr};
WorkerStartCallback callback_;
uv_thread_t selfThreadId_ {0};
};
} // namespace CompilerRuntime::WorkerModule
#endif // JS_WORKER_MODULE_WORKER_WORKER_RUNNER_H_