17c804472Sopenharmony_ci/*
27c804472Sopenharmony_ci * Copyright (c) 2023 Huawei Device Co., Ltd.
37c804472Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License");
47c804472Sopenharmony_ci * you may not use this file except in compliance with the License.
57c804472Sopenharmony_ci * You may obtain a copy of the License at
67c804472Sopenharmony_ci *
77c804472Sopenharmony_ci *     http://www.apache.org/licenses/LICENSE-2.0
87c804472Sopenharmony_ci *
97c804472Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software
107c804472Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS,
117c804472Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
127c804472Sopenharmony_ci * See the License for the specific language governing permissions and
137c804472Sopenharmony_ci * limitations under the License.
147c804472Sopenharmony_ci */
157c804472Sopenharmony_ci
167c804472Sopenharmony_ci#ifndef EVENT_RUNNER_H
177c804472Sopenharmony_ci#define EVENT_RUNNER_H
187c804472Sopenharmony_ci
197c804472Sopenharmony_ci#include <memory>
207c804472Sopenharmony_ci#include <mutex>
217c804472Sopenharmony_ci#include <thread>
227c804472Sopenharmony_ci#include "EventQueue.h"
237c804472Sopenharmony_ci
247c804472Sopenharmony_cinamespace OHOS::AppExecFwk {
257c804472Sopenharmony_ciclass EventRunner final {
267c804472Sopenharmony_cipublic:
277c804472Sopenharmony_ci    EventRunner() = default;
287c804472Sopenharmony_ci    ~EventRunner() = default;
297c804472Sopenharmony_ci    static EventRunner& Current();
307c804472Sopenharmony_ci    static EventRunner& GetMainEventRunner();
317c804472Sopenharmony_ci    void SetMainThreadId(std::thread::id id);
327c804472Sopenharmony_ci    std::thread::id GetThreadId();
337c804472Sopenharmony_ci    bool IsCurrentRunnerThread();
347c804472Sopenharmony_ci    void Run();
357c804472Sopenharmony_ci
367c804472Sopenharmony_ci    void PushTask(const Callback &callback, std::chrono::steady_clock::time_point targetTime);
377c804472Sopenharmony_ci
387c804472Sopenharmony_ciprivate:
397c804472Sopenharmony_ci    EventRunner(const EventRunner&) = delete;
407c804472Sopenharmony_ci    EventRunner &operator=(const EventRunner&) = delete;
417c804472Sopenharmony_ci    std::thread::id threadId;
427c804472Sopenharmony_ci    EventQueue queue;
437c804472Sopenharmony_ci    std::mutex mutex;
447c804472Sopenharmony_ci};
457c804472Sopenharmony_ci}
467c804472Sopenharmony_ci#endif // EVENT_RUNNER_H
47