| /foundation/aafwk/standard/test/systemtest/common/task_dispatcher/src/ |
| D | task_dispatcher_tools.cpp | 54 TaskList &TaskList::addFunc(std::shared_ptr<Runnable> runnable) in addFunc()
167 auto runnable = funcList.front(); in executeSyncDispatch() local
179 auto runnable = funcList.front(); in executeAsyncDispatch() local
192 auto runnable = funcList.front(); in executeDelayDispatch() local
206 auto runnable = funcList.front(); in executeSyncDispatchBarrier() local
218 auto runnable = funcList.front(); in executeAsyncDispatchBarrier() local
236 auto runnable = funcList.front(); in executeAsyncGroupDispatch() local
260 auto runnable = funcList.front(); in executeGroupDispatchNotify() local
273 …auto runnable = std::make_shared<IteratableTask<long>>([func](long applyTime) { (*func.get())(); }… in executeApplyDispatch() local
|
| /foundation/aafwk/standard/common/task_dispatcher/include/task/ |
| D | task_handler_libevent_adapter.h | 31 bool Dispatch(const std::shared_ptr<Runnable> &runnable) override in Dispatch()
37 bool Dispatch(const std::shared_ptr<Runnable> &runnable, long delayMs) override in Dispatch()
42 bool DispatchSync(const std::shared_ptr<Runnable> &runnable) override in DispatchSync()
|
| /foundation/aafwk/standard/common/task_dispatcher/src/dispatcher/ |
| D | spec_task_dispatcher.cpp | 32 ErrCode SpecTaskDispatcher::SyncDispatch(const std::shared_ptr<Runnable> &runnable) in SyncDispatch()
54 …:shared_ptr<Revocable> SpecTaskDispatcher::AsyncDispatch(const std::shared_ptr<Runnable> &runnable) in AsyncDispatch()
74 …shared_ptr<Revocable> SpecTaskDispatcher::DelayDispatch(const std::shared_ptr<Runnable> &runnable,… in DelayDispatch()
|
| D | parallel_task_dispatcher_base.cpp | 53 ErrCode ParallelTaskDispatcherBase::SyncDispatch(const std::shared_ptr<Runnable> &runnable) in SyncDispatch()
82 …ptr<Revocable> ParallelTaskDispatcherBase::AsyncDispatch(const std::shared_ptr<Runnable> &runnable) in AsyncDispatch()
107 const std::shared_ptr<Runnable> &runnable, long delayMs) in DelayDispatch()
138 const std::shared_ptr<Group> &group, const std::shared_ptr<Runnable> &runnable) in AsyncGroupDispatch()
|
| D | parallel_task_dispatcher.cpp | 35 ErrCode ParallelTaskDispatcher::SyncDispatchBarrier(const std::shared_ptr<Runnable> &runnable) in SyncDispatchBarrier()
64 ErrCode ParallelTaskDispatcher::AsyncDispatchBarrier(const std::shared_ptr<Runnable> &runnable) in AsyncDispatchBarrier()
|
| D | serial_task_dispatcher.cpp | 44 ErrCode SerialTaskDispatcher::SyncDispatch(const std::shared_ptr<Runnable> &runnable) in SyncDispatch()
71 …hared_ptr<Revocable> SerialTaskDispatcher::AsyncDispatch(const std::shared_ptr<Runnable> &runnable) in AsyncDispatch()
91 …ared_ptr<Revocable> SerialTaskDispatcher::DelayDispatch(const std::shared_ptr<Runnable> &runnable,… in DelayDispatch()
|
| /foundation/aafwk/standard/common/task_dispatcher/test/unittest/sync_task_test/ |
| D | sync_task_test.cpp | 54 auto runnable = std::make_shared<Runnable>([]() { in __anon983328470102() variable
88 auto runnable = std::make_shared<Runnable>([&count]() { in __anon983328470202() variable
123 auto runnable = std::make_shared<Runnable>([&count]() { in __anon983328470302() variable
|
| /foundation/aafwk/standard/common/task_dispatcher/test/unittest/task_executor_test/ |
| D | task_executor_test.cpp | 84 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>(TestTask); variable
109 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>(TestTask); variable
200 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>(TestTask); variable
240 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>(TestTask); variable
|
| /foundation/aafwk/standard/common/task_dispatcher/src/task/ |
| D | sync_task.cpp | 29 SyncTask::SyncTask(const std::shared_ptr<Runnable> &runnable, TaskPriority priority, in SyncTask()
|
| D | task.cpp | 25 Task::Task(const std::shared_ptr<Runnable> &runnable, const TaskPriority priority, in Task()
|
| /foundation/aafwk/standard/common/task_dispatcher/test/unittest/barrier_handler_test/ |
| D | barrier_handler_test.cpp | 79 …std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { GTEST_LOG_(INFO) << name <… in __anon238147110102() variable
99 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { in __anon238147110202() variable
|
| /foundation/appexecfwk/standard/tools/zip/src/ |
| D | zip_utils.cpp | 33 void PostTask(const std::shared_ptr<Runnable> &runnable) in PostTask()
|
| /foundation/aafwk/standard/common/task_dispatcher/test/unittest/base_task_dispatcher_test/ |
| D | base_task_dispatcher_test.cpp | 383 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>(TestTask); variable
400 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>(TestTask); variable
|
| /foundation/distributeddatamgr/appdatamgr/frameworks/innerkitsimpl/native_dataability/src/ |
| D | ishared_result_set_stub.cpp | 123 auto runnable = runnables_.Pop(); in Run() local
|
| /foundation/communication/dsoftbus/core/connection/common/include/ |
| D | softbus_thread_pool.h | 40 bool runnable; member
|
| /foundation/aafwk/standard/common/test/moduletest/task_dispatcher/parallel_task_dispatcher_module_test/ |
| D | parallel_task_dispatcher_module_test.cpp | 70 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { in __anon812e52830102() variable
186 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { in __anon812e52830702() variable
|
| /foundation/aafwk/standard/common/task_dispatcher/test/unittest/task_test/ |
| D | task_test.cpp | 58 …std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { GTEST_LOG_(INFO) << runStr… in CreateTask() local
|
| /foundation/aafwk/standard/common/test/moduletest/task_dispatcher/global_task_dispatcher_module_test/ |
| D | global_task_dispatcher_module_test.cpp | 180 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { in __anon85105bcb0602() variable
|
| /foundation/aafwk/standard/common/test/moduletest/task_dispatcher/serial_task_dispatcher_module_test/ |
| D | serial_task_dispatcher_module_test.cpp | 75 std::shared_ptr<Runnable> runnable = std::make_shared<Runnable>([&]() { in __anon0b019b490102() variable
|