| /foundation/communication/dsoftbus/tests/adapter/unittest/ |
| D | softbus_thread_test.cpp | 63 SoftBusThread thread = SoftBusThreadGetSelf(); in ThreadSelfTest() local
443 SoftBusThread thread = 0; variable
458 SoftBusThread thread = 0; variable
477 SoftBusThread thread = 0; variable
497 SoftBusThread thread = 0; variable
516 SoftBusThread thread = 0; variable
535 SoftBusThread thread = 0; variable
554 SoftBusThread thread = 0; variable
573 SoftBusThread thread = 0; variable
593 SoftBusThread thread = 0; variable
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/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
177 void ThreadDelete(Thread *thread) in ThreadDelete()
191 void ThreadPostTask(Thread *thread, TaskFunc func, void *context) in ThreadPostTask()
205 Reactor *ThreadGetReactor(const Thread *thread) in ThreadGetReactor()
|
| /foundation/ability/ability_runtime/test/unittest/appkit/child_main_thread_test/ |
| D | child_main_thread_test.cpp | 74 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
91 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
109 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
128 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
162 sptr<ChildMainThread> thread = sptr<ChildMainThread>(new (std::nothrow) ChildMainThread()); variable
|
| /foundation/ai/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/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| D | thread.h | 23 thread() noexcept in thread() function
29 explicit thread(const char* name, qos qos_, Fn&& fn, Args&&... args) in thread() function
42 explicit thread(qos qos_, Fn&& fn, Args&&... args) in thread() function
57 explicit thread(Fn&& fn, Args&& ... args) in thread() function
71 thread(thread&& th) noexcept in thread() function
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| D | worker_manager.cpp | 24 for (auto& thread : tgwrap.threads) { in JoinRtg() local
50 for (auto& thread : tgwrap.threads) { in JoinTG() local
74 for (auto& thread : groupCtl[qos].threads) { in LeaveTG() local
|
| D | cpuworker_manager.cpp | 77 CPUEUTask* CPUWorkerManager::PickUpTask(WorkerThread* thread) in PickUpTask()
90 CPUEUTask* CPUWorkerManager::PickUpTaskBatch(WorkerThread* thread) in PickUpTaskBatch()
136 void CPUWorkerManager::TryMoveLocal2Global(WorkerThread* thread) in TryMoveLocal2Global()
147 unsigned int CPUWorkerManager::StealTaskBatch(WorkerThread* thread) in StealTaskBatch()
175 PollerRet CPUWorkerManager::TryPoll(const WorkerThread* thread, int timeout) in TryPoll()
206 void CPUWorkerManager::NotifyTaskPicked(const WorkerThread* thread) in NotifyTaskPicked()
211 void CPUWorkerManager::WorkerRetired(WorkerThread* thread) in WorkerRetired()
|
| D | scpuworker_manager.cpp | 65 WorkerAction SCPUWorkerManager::WorkerIdleAction(const WorkerThread* thread) in WorkerIdleAction()
121 void SCPUWorkerManager::WorkerPrepare(WorkerThread* thread) in WorkerIdleAction()
|
| D | worker_thread.cpp | 57 void SetThreadAttr(WorkerThread* thread, const QoS& qos) in SetThreadAttr()
|
| D | worker_thread.h | 172 std::thread thread; variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| D | auto_sync_timer_test.cpp | 170 std::thread thread([&finished] { in __anond8e41c100102() variable
202 std::thread thread([&finished] { in __anond8e41c100202() variable
233 std::thread thread([&finished] { in __anond8e41c100302() variable
310 std::thread thread([&finished] { in __anond8e41c100402() variable
|
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/texture_encode/ |
| D | hwe_osdep.cpp | 217 int32_t HWE_PthreadJoin(HWE_Pthread thread) in HWE_PthreadJoin()
231 int32_t HWE_SetThreadAffinityMask(const HWE_Pthread *thread, uint32_t cpuNum, const uint32_t *cpuId… in HWE_SetThreadAffinityMask()
266 int32_t HWE_SetThreadPriority(const HWE_Pthread *thread, int32_t schedPriority) in HWE_SetThreadPriority()
|
| /foundation/communication/dsoftbus/adapter/common/kernel/posix/ |
| D | softbus_adapter_thread.c | 253 int32_t SoftBusThreadCreate(SoftBusThread *thread, SoftBusThreadAttr *threadAttr, in SoftBusThreadCreate()
302 int32_t SoftBusThreadJoin(SoftBusThread thread, void **value) in SoftBusThreadJoin()
318 int32_t SoftBusThreadSetName(SoftBusThread thread, const char *name) in SoftBusThreadSetName()
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
| D | event_runner.cpp | 98 bool Deposit(std::unique_ptr<std::thread> &thread, const ExitFunction &threadExit) in Deposit()
127 std::unique_ptr<std::thread> thread; member
349 inline bool Attach(std::unique_ptr<std::thread> &thread) in Attach()
424 auto thread = in Create() local
|
| /foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/ |
| D | thread_pool.h | 47 mutable std::thread thread; member
|
| /foundation/communication/netmanager_base/test/netcommon/unittest/net_common_test/ |
| D | errorcode_convertor_test.cpp | 56 std::thread thread([this]() { in AllTest001() local
|
| /foundation/distributeddatamgr/pasteboard/interfaces/kits/napi/src/ |
| D | napi_systempasteboard.cpp | 414 std::thread thread([block]() { in IsRemoteData() local
436 std::thread thread([block, &bundleName]() mutable { in GetDataSource() local
477 std::thread thread([block, mimeType]() { in HasDataType() local
499 std::thread thread([block]() { in ClearDataSync() local
523 std::thread thread([block, &obj]() mutable { in GetDataSync() local
565 std::thread thread([block, pasteData]() { in SetDataSync() local
588 std::thread thread([block]() { in HasDataSync() local
|
| /foundation/CastEngine/castengine_wifi_display/tests/demo/network/ |
| D | udp_server_demo.cpp | 81 pthread_t thread; in main() local
|
| /foundation/ai/ai_engine/services/common/platform/threadpool/include/ |
| D | thread.h | 112 void SetThread(Thread *thread) in SetThread()
|
| /foundation/ai/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()
|
| /foundation/resourceschedule/ffrt/src/util/ |
| D | worker_monitor.cpp | 71 for (auto& thread : workerGroup[i].threads) { in CheckWorkerStatus() local
|
| /foundation/ability/ability_runtime/test/fuzztest/applifecycledeal_fuzzer/ |
| D | applifecycledeal_fuzzer.cpp | 65 sptr<IAppScheduler> thread = nullptr; in DoSomethingInterestingWithMyAPI() local
|
| /foundation/ai/ai_engine/test/common/threadpool/ |
| D | thread_pool_test.cpp | 125 Thread thread; variable
|
| /foundation/multimedia/player_framework/services/services/avcodec/server/ |
| D | avcodec_server.cpp | 58 …std::unique_ptr<std::thread> thread = std::make_unique<std::thread>(&AVCodecServer::ExitProcessor,… in ~AVCodecServer() local
189 …std::unique_ptr<std::thread> thread = std::make_unique<std::thread>(&AVCodecServer::ExitProcessor,… in Release() local
|
| /foundation/multimedia/media_library/frameworks/services/media_async_worker/src/ |
| D | medialibrary_async_worker.cpp | 53 for (auto &thread : threads_) { in ~MediaLibraryAsyncWorker() local
|