Home
last modified time | relevance | path

Searched refs:EventRunner (Results 1 – 25 of 277) sorted by relevance

12345678910>>...12

/base/notification/eventhandler/interfaces/inner_api/
Devent_runner.h29 class EventRunner final {
31 EventRunner() = delete;
32 ~EventRunner();
33 DISALLOW_COPY_AND_MOVE(EventRunner);
41 static std::shared_ptr<EventRunner> Create(bool inNewThread = true);
49 static std::shared_ptr<EventRunner> Create(const std::string &threadName);
58 static inline std::shared_ptr<EventRunner> Create(const char *threadName) in Create()
68 static std::shared_ptr<EventRunner> Current();
200 static std::shared_ptr<EventRunner> GetMainEventRunner();
203 explicit EventRunner(bool deposit);
[all …]
/base/notification/eventhandler/frameworks/eventhandler/src/
Devent_runner.cpp274 explicit EventRunnerImpl(const std::shared_ptr<EventRunner> &runner) : EventInnerRunner(runner) in EventRunnerImpl()
320 std::weak_ptr<EventRunner> oldRunner = currentEventRunner; in Run()
377 EventInnerRunner::EventInnerRunner(const std::shared_ptr<EventRunner> &runner) in EventInnerRunner()
381 std::shared_ptr<EventRunner> EventInnerRunner::GetCurrentEventRunner() in GetCurrentEventRunner()
383 const std::weak_ptr<EventRunner> &wp = currentEventRunner; in GetCurrentEventRunner()
387 ThreadLocalData<std::weak_ptr<EventRunner>> EventInnerRunner::currentEventRunner;
400 std::shared_ptr<EventRunner> EventRunner::mainRunner_;
402 std::shared_ptr<EventRunner> EventRunner::Create(bool inNewThread) in Create()
409 std::shared_ptr<EventRunner> sp(new EventRunner(false)); in Create()
417 std::shared_ptr<EventRunner> EventRunner::Create(const std::string &threadName) in Create()
[all …]
/base/notification/eventhandler/test/systemtest/ems_event_runner_system_test/
Dems_event_runner_system_test.cpp236 auto runner = EventRunner::Create(true);
255 auto runner = EventRunner::Create(true);
273 auto runner = EventRunner::Create(true);
291 auto runner = EventRunner::Create(true);
309 auto runner = EventRunner::Create(true);
327 auto runner = EventRunner::Create(true);
346 auto runner = EventRunner::Create(true);
364 auto runner = EventRunner::Create();
382 auto runner = EventRunner::Create();
400 auto runner = EventRunner::Create(true);
[all …]
/base/telephony/core_service/services/core/include/
Drunner_pool.h28 std::shared_ptr<AppExecFwk::EventRunner> GetCommonRunner();
29 std::shared_ptr<AppExecFwk::EventRunner> GetSimDbAndFileRunner();
32 std::shared_ptr<AppExecFwk::EventRunner> CreateRunner(const std::string &name);
37 std::shared_ptr<AppExecFwk::EventRunner> commonRunner_ = nullptr;
38 std::shared_ptr<AppExecFwk::EventRunner> simDbAndFileRunner_ = nullptr;
/base/telephony/sms_mms/services/sms/include/
Drunner_pool.h30 std::shared_ptr<AppExecFwk::EventRunner> GetSmsCommonRunner();
31 std::shared_ptr<AppExecFwk::EventRunner> GetSmsSendReceiveRunnerBySlotId(const int32_t slotId);
34 std::shared_ptr<AppExecFwk::EventRunner> CreateRunner(const std::string &name);
39 std::shared_ptr<AppExecFwk::EventRunner> smsCommonRunner_ = nullptr;
40 std::map<uint32_t, std::shared_ptr<AppExecFwk::EventRunner>> smsSendReceiveRunnerMap_;
Dsms_receive_manager.h38 std::shared_ptr<AppExecFwk::EventRunner> gsmSmsReceiveRunner_;
39 std::shared_ptr<AppExecFwk::EventRunner> cdmaSmsReceiveRunner_;
/base/notification/eventhandler/test/systemtest/ems_event_handler_system_test/
Dems_event_handler_test.cpp168 explicit MyEventHandler(const std::shared_ptr<EventRunner> &runner) : EventHandler(runner) in MyEventHandler()
210 explicit TestEventHandler(const std::shared_ptr<EventRunner> &runner) : EventHandler(runner) in TestEventHandler()
247 auto runner = EventRunner::Create(true); in ProcessEventTest()
273 auto runner = EventRunner::Create(true);
288 auto runner = EventRunner::Create(true);
303 auto runner = EventRunner::Create(true);
319 auto runner = EventRunner::Create(true);
335 auto runner = EventRunner::Create(true);
351 auto runner = EventRunner::Create(true);
367 auto runner = EventRunner::Create(true);
[all …]
/base/notification/common_event_service/frameworks/core/include/
Dcommon_event_listener.h30 using EventRunner = OHOS::AppExecFwk::EventRunner; variable
59 std::shared_ptr<EventRunner> GetCommonRunner();
66 static std::shared_ptr<EventRunner> commonRunner_;
71 std::shared_ptr<EventRunner> runner_;
/base/notification/eventhandler/
DREADME_zh.md4 ​ EventHandler提供了OpenHarmony线程间通信的基本能力，可以通过EventRunner创建新线程，将耗时的操作抛到新线程上执行，从而实现在不阻塞原来的线程的基础上…
10 | EventRunner | 消息队列的循环分发器，每个线程只有一个EventRunner，主要用于管理消息队列EventQueue,不断地从队列中取出InnerEvent分发至对应的Event…
12 | EventHandler | 发送和处理消息的核心类，通过绑定一个EventRunner实现对消息队列进行循环分发的功能。 |
13 | EventQueue | 线程消息队列，管理InnerEvent，在初始化EventRunner对象时需要创建一个与之关联的EventQueue。 |
/base/telephony/sms_mms/services/sms/
Drunner_pool.cpp53 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::CreateRunner(const std::string &name) in CreateRunner()
55 auto runner = AppExecFwk::EventRunner::Create(name); in CreateRunner()
64 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::GetSmsCommonRunner() in GetSmsCommonRunner()
69 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::GetSmsSendReceiveRunnerBySlotId(const int32_t … in GetSmsSendReceiveRunnerBySlotId()
72 …std::map<uint32_t, std::shared_ptr<AppExecFwk::EventRunner>>::iterator iter = smsSendReceiveRunner… in GetSmsSendReceiveRunnerBySlotId()
/base/telephony/core_service/services/core/src/
Drunner_pool.cpp44 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::CreateRunner(const std::string &name) in CreateRunner()
46 auto runner = AppExecFwk::EventRunner::Create(name); in CreateRunner()
55 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::GetCommonRunner() in GetCommonRunner()
60 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::GetSimDbAndFileRunner() in GetSimDbAndFileRunner()
/base/notification/eventhandler/frameworks/eventhandler/include/
Devent_inner_runner.h29 explicit EventInnerRunner(const std::shared_ptr<EventRunner> &runner);
33 static std::shared_ptr<EventRunner> GetCurrentEventRunner();
65 std::weak_ptr<EventRunner> owner_;
67 static ThreadLocalData<std::weak_ptr<EventRunner>> currentEventRunner;
/base/notification/eventhandler/frameworks/eventhandler/test/unittest/
Dlib_event_handler_event_runner_test.cpp138 auto handler = std::make_shared<EventHandler>(EventRunner::Create());
161 auto runner = EventRunner::Create(false);
188 auto handler = std::make_shared<EventHandler>(EventRunner::Create(threadName));
208 auto handler = std::make_shared<EventHandler>(EventRunner::Create("threadName"));
228 auto runner = EventRunner::Create(false);
257 auto runner = EventRunner::Create(false);
284 auto runner = EventRunner::Create();
306 auto runner = EventRunner::Create(false);
331 auto runner = EventRunner::Create(false);
339 auto currentRunner = EventRunner::Current(); in __anon9b0e7c740802()
[all …]
/base/notification/eventhandler/frameworks/test/moduletest/
Devent_handler_set_get_remove_module_test.cpp61 auto myRunner = EventRunner::Create(false);
81 auto myRunner = EventRunner::Create(false);
100 auto myRunner = EventRunner::Create(false);
136 auto myRunner = EventRunner::Create(false);
158 auto myRunner = EventRunner::Create(false);
178 auto myRunner = EventRunner::Create(false);
199 auto myRunner = EventRunner::Create();
222 auto myRunner = EventRunner::Create();
241 auto myRunner = EventRunner::Create(false);
245 auto inRunner = EventRunner::Create(false); in __anon790ca3770302()
[all …]
Devent_handler_post_task_module_test.cpp63 auto myRunner = EventRunner::Create(false);
89 auto myRunner = EventRunner::Create(false);
114 auto myRunner = EventRunner::Create(false);
140 auto myRunner = EventRunner::Create(false);
165 auto myRunner = EventRunner::Create(false);
191 auto myRunner = EventRunner::Create(false);
221 auto myRunner = EventRunner::Create(false);
Devent_handler_send_sync_event_module_test.cpp61 auto myRunner = EventRunner::Create(); in SendEventWithSmartPtr()
145 auto myRunner = EventRunner::Create(false);
165 auto myRunner = EventRunner::Create(false);
187 auto myRunner = EventRunner::Create();
213 auto myRunner = EventRunner::Create();
235 auto myRunner = EventRunner::Create();
260 auto myRunner = EventRunner::Create();
356 auto myRunner = EventRunner::Create();
381 auto myRunner = EventRunner::Create();
Devent_handler_fd_listener_module_test.cpp145 auto myRunner = EventRunner::Create(false);
172 auto myRunner = EventRunner::Create(false);
197 auto myRunner = EventRunner::Create(true);
221 auto myRunner = EventRunner::Create(true);
268 auto myRunner = EventRunner::Create(false);
300 auto myRunner = EventRunner::Create(false);
332 auto myRunner = EventRunner::Create(false);
334 auto otherHandler = std::make_shared<MyEventHandler>(EventRunner::Create());
368 auto myRunner = EventRunner::Create(false);
/base/telephony/cellular_data/services/include/
Drunner_pool.h28 std::shared_ptr<AppExecFwk::EventRunner> GetCommonRunner();
31 std::shared_ptr<AppExecFwk::EventRunner> CreateRunner(const std::string &name);
36 std::shared_ptr<AppExecFwk::EventRunner> commonRunner_ = nullptr;
/base/telephony/cellular_data/services/src/
Drunner_pool.cpp43 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::CreateRunner(const std::string &name) in CreateRunner()
45 auto runner = AppExecFwk::EventRunner::Create(name); in CreateRunner()
54 std::shared_ptr<AppExecFwk::EventRunner> RunnerPool::GetCommonRunner() in GetCommonRunner()
/base/notification/common_event_service/services/include/
Dordered_event_handler.h24 using EventRunner = OHOS::AppExecFwk::EventRunner; variable
38 …const std::shared_ptr<EventRunner> &runner, const std::shared_ptr<CommonEventControlManager> &cont…
/base/telephony/core_service/services/sim/include/
Dsim_account_manager.h49 std::shared_ptr<AppExecFwk::EventRunner> operatorConfigCacheRunner_;
50 std::shared_ptr<AppExecFwk::EventRunner> simStateTrackerRunner_;
51 std::shared_ptr<AppExecFwk::EventRunner> privilegesRunner_;
/base/notification/common_event_service/services/test/unittest/
Dordered_event_handler_test.cpp58 std::shared_ptr<EventRunner> runner = nullptr; in HWTEST_F()
74 std::shared_ptr<EventRunner> runner = nullptr; in HWTEST_F()
91 std::shared_ptr<EventRunner> runner = nullptr; in HWTEST_F()
108 std::shared_ptr<EventRunner> runner = nullptr; in HWTEST_F()
/base/telephony/cellular_call/vendor/ims/services/ims_base/include/
Dims_base.h38 eventLoop_ = AppExecFwk::EventRunner::Create(loopName); in CreateEventLoop()
47 std::shared_ptr<AppExecFwk::EventRunner> eventLoop_ = nullptr;
/base/hiviewdfx/hicollie/frameworks/native/test/unittest/common/
Dhandler_checker_test.cpp30 explicit TestEventHandler(const std::shared_ptr<EventRunner> &runner) in TestEventHandler()
71 auto runner = EventRunner::Create(true);
98 auto runner = EventRunner::Create(true);
131 auto runner = EventRunner::Create(true);
/base/request/request/services/service/rust/src/c_wrapper/source/
Dc_event_handler.cpp32 std::shared_ptr<OHOS::AppExecFwk::EventRunner> runner = in RequestInitServiceHandler()
33 OHOS::AppExecFwk::EventRunner::Create("DownloadServiceAbility"); in RequestInitServiceHandler()

12345678910>>...12