| /foundation/aafwk/standard/common/task_dispatcher/test/unittest/work_thread_test/ |
| D | work_thread_test.cpp | 68 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
73 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
106 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
114 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
150 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
186 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
221 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
227 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
233 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
258 …std::shared_ptr<WorkerThread> thread = std::make_shared<WorkerThread>(delegate, firstTask, factory… variable
[all …]
|
| /foundation/communication/dsoftbus/tests/adapter/unittest/ |
| D | softbus_thread_test.cpp | 61 SoftBusThread thread = SoftBusThreadGetSelf(); in ThreadSelfTest() local
434 SoftBusThread thread = 0; variable
449 SoftBusThread thread = 0; variable
467 SoftBusThread thread = 0; variable
487 SoftBusThread thread = 0; variable
508 SoftBusThread thread = 0; variable
529 SoftBusThread thread = 0; variable
550 SoftBusThread thread = 0; variable
571 SoftBusThread thread = 0; variable
592 SoftBusThread thread = 0; variable
[all …]
|
| /foundation/communication/bluetooth/services/bluetooth_standard/stack/platform/linux/ |
| D | thread_linux.c | 44 Thread *thread; member
69 Thread *thread = startPromise->thread; in ThreadStartFunc() local
99 int32_t ThreadIsSelf(const Thread *thread) in ThreadIsSelf()
109 static void ThreadStop(Thread *thread) in ThreadStop()
125 Thread *thread = (Thread *)calloc(1, (sizeof(Thread))); in ThreadCreate() local
176 void ThreadDelete(Thread *thread) in ThreadDelete()
190 void ThreadPostTask(Thread *thread, TaskFunc func, void *context) in ThreadPostTask()
204 Reactor *ThreadGetReactor(const Thread *thread) in ThreadGetReactor()
|
| /foundation/ai/engine/services/common/platform/threadpool/source/ |
| D | thread_pool.cpp | 69 std::shared_ptr<Thread> thread; in Pop() local
87 void ThreadPool::Push(std::shared_ptr<Thread> &thread) in Push()
111 for (auto &thread : busyThreads_) { in StopThreads() local
125 for (auto &thread : busyThreads_) { in StopThreads() local
142 for (auto &thread : busyThreads_) { in StopThreads() local
|
| /foundation/communication/dsoftbus/adapter/common/kernel/liteos_a/ |
| D | softbus_adapter_thread.c | 271 int32_t SoftBusThreadCreate(SoftBusThread *thread, SoftBusThreadAttr *threadAttr, void *(*threadEnt… in SoftBusThreadCreate()
316 int32_t SoftBusThreadJoin(SoftBusThread thread, void **value) in SoftBusThreadJoin()
332 int32_t SoftBusThreadSetName(SoftBusThread thread, const char *name) in SoftBusThreadSetName()
|
| /foundation/appexecfwk/standard/libs/libeventhandler/src/ |
| D | event_runner.cpp | 94 bool Deposit(std::unique_ptr<std::thread> &thread, const ExitFunction &threadExit) in Deposit()
123 std::unique_ptr<std::thread> thread; member
351 inline bool Attach(std::unique_ptr<std::thread> &thread) in Attach()
426 auto thread = in Create() local
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/adapter/autils/src/thread_pool/ |
| D | kv_store_thread_pool_impl.cpp | 54 for (auto thread = threadList.begin(); thread != threadList.end(); thread++) { in Stop() local
|
| /foundation/graphic/standard/frameworks/wmtest/test/ |
| D | crash_native_test_1.cpp | 68 std::thread thread(threadFunc); in Run() local
|
| /foundation/aafwk/standard/services/appmgr/src/ |
| D | app_lifecycle_deal.cpp | 124 void AppLifeCycleDeal::SetApplicationClient(const sptr<IAppScheduler> &thread) in SetApplicationClient()
|
| /foundation/ai/engine/services/server/server_executor/source/ |
| D | engine.cpp | 29 Engine::Engine(std::shared_ptr<Plugin> &plugin, std::shared_ptr<Thread> &thread, in Engine()
|
| D | engine_manager.cpp | 203 std::shared_ptr<Thread> thread = threadPool->Pop(); in CreateEngine() local
|
| /foundation/ai/engine/services/common/platform/threadpool/include/ |
| D | thread.h | 112 void SetThread(Thread *thread) in SetThread()
|
| /foundation/multimedia/audio_standard/services/src/audio_policy/client/ |
| D | audio_policy_manager_listener_stub.cpp | 30 for (auto &thread : interruptThreads_) { in ~AudioPolicyManagerListenerStub() local
|
| /foundation/communication/dsoftbus/components/nstackx_mini/nstackx_util/platform/liteos/ |
| D | sys_util.c | 71 void PthreadJoin(pthread_t thread, void **retval) in PthreadJoin()
|
| /foundation/ai/engine/test/common/threadpool/ |
| D | thread_pool_test.cpp | 125 Thread thread; variable
|
| /foundation/resourceschedule/frame_aware_sched/test/unittest/phone/ |
| D | frame_msg_intf_test.cpp | 58 std::shared_ptr<AppExecFwk::EventHandler> thread = FrameMsgIntf::GetInstance().threadHandler_; in TearDown() local
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
| D | sys_util.c | 131 void PthreadJoin(pthread_t thread, void **retval) in PthreadJoin()
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/common/src/ |
| D | task_pool_impl.cpp | 219 std::thread thread([this]() { in SpawnThreads() local
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/syncer/ |
| D | generic_virtual_device.cpp | 138 std::thread thread([context, communicateHandle, inMsg]() { in MessageCallback() local
|
| D | virtual_communicator_aggregator.cpp | 184 std::thread thread([communicator, srcTarget, dstTarget, msg, onDispatch]() { in DispatchMessage() local
|
| /foundation/distributeddatamgr/appdatamgr/frameworks/innerkitsimpl/native_preferences/src/ |
| D | task_pool.cpp | 234 std::thread thread([this]() { TaskWorker(); }); in SpawnThreads() local
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| D | sys_util.c | 183 void PthreadJoin(pthread_t thread, void **retval) in PthreadJoin()
|
| /foundation/communication/bluetooth/services/bluetooth_standard/stack/src/hci/cmd/ |
| D | hci_cmd.c | 138 Thread *thread = BTM_GetProcessingThread(); in HciCmdOnCmdTimeout() local
|
| /foundation/aafwk/standard/frameworks/kits/test/moduletest/cpp/abilitytest/ |
| D | data_ability_helper_module_test.cpp | 73 sptr<AppExecFwk::AbilityThread> thread = nullptr; variable
99 sptr<AppExecFwk::AbilityThread> thread = nullptr; variable
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/test/moduletest/common/distributeddb/src/ |
| D | distributeddb_kv_concurrency_crud_test.cpp | 108 …std::thread thread = std::thread(ConcurOperThread, reinterpret_cast<ConcurParam *>(kvThreadParam)); in KvCalculateTime() local
|