| /foundation/ai/ai_engine/services/common/platform/threadpool/source/ |
| H A D | thread.cpp | 41 Thread::Thread() in Thread() function in OHOS::AI::Thread
47 Thread::~Thread() in ~Thread()
55 void Thread::SetStackSize(const size_t size) in SetStackSize()
60 Thread::ThreadStatus Thread::Status() const in Status()
65 const IWorker *Thread::GetWorker() const in GetWorker()
70 void Thread::SetWorker(IWorker *pWorker) in SetWorker()
82 bool Thread
[all...] |
| H A D | thread_pool.cpp | 65 std::shared_ptr<Thread> ThreadPool::Pop() in Pop()
69 std::shared_ptr<Thread> thread; in Pop()
71 Thread *ptr = nullptr; in Pop()
72 AIE_NEW(ptr, Thread); in Pop()
87 void ThreadPool::Push(std::shared_ptr<Thread> &thread) in Push()
|
| /foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/ |
| H A D | thread.h | 35 class Thread { class
37 explicit Thread(ThreadPriority priority = ThreadPriority::HIGH) noexcept;
39 Thread(const Thread&) = delete;
41 Thread& operator=(const Thread&) = delete;
43 Thread(Thread&& other) noexcept;
45 Thread& operator=(Thread
[all...] |
| H A D | task.h | 67 std::unique_ptr<OSAL::Thread> loop_;
|
| /foundation/multimedia/media_foundation/src/osal/task/pthread/ |
| H A D | thread.cpp | 16 #define HST_LOG_TAG "Thread"
23 constexpr OHOS::HiviewDFX::HiLogLabel LABEL = { LOG_CORE, LOG_DOMAIN_FOUNDATION, "Thread" };
28 Thread::Thread(ThreadPriority priority) noexcept : id_(), name_(), priority_(priority), state_() in state_()
32 Thread::Thread(Thread&& other) noexcept
37 Thread& Thread::operator=(Thread
[all...] |
| H A D | pipeline_threadpool.cpp | 119 loop_ = CppExt::make_unique<Thread>(ConvertPriorityType(priority)); in PipeLineThread()
|
| /foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
| H A D | thread.h | 35 class Thread { class
37 explicit Thread(ThreadPriority priority = ThreadPriority::HIGH) noexcept;
39 Thread(const Thread&) = delete;
41 Thread& operator=(const Thread&) = delete;
43 Thread(Thread&& other) noexcept;
45 Thread& operator=(Thread
[all...] |
| H A D | pipeline_threadpool.h | 51 std::unique_ptr<Thread> loop_;
|
| /foundation/multimedia/media_foundation/engine/foundation/osal/thread/ |
| H A D | thread.cpp | 16 #define HST_LOG_TAG "Thread"
24 Thread::Thread(ThreadPriority priority) noexcept : id_(), name_(), priority_(priority), state_() in state_()
28 Thread::Thread(Thread&& other) noexcept
33 Thread& Thread::operator=(Thread&& other) noexcept
44 Thread
[all...] |
| H A D | task.cpp | 28 loop_ = CppExt::make_unique<OSAL::Thread>(priority); in Task()
53 loop_ = CppExt::make_unique<OSAL::Thread>(priority_); in Start()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/include/ |
| H A D | thread.h | 31 typedef struct Thread Thread; typedef
35 * @brief Perform instantiation of the Thread.
37 * @param name Thread name, length less or equal 16 bytes.
38 * @return Thread pointer.
41 Thread *ThreadCreate(const char *name);
44 * @brief Destroy instantiation of the Thread.
46 * @param thread Thread pointer.
49 void ThreadDelete(Thread *thread);
52 * @brief Post Task to Thread
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | thread_linux.c | 34 typedef struct Thread { struct
44 Thread *thread;
59 LOG_ERROR("Thread: Queue Dequeue failed."); in ReadyToRead()
69 Thread *thread = startPromise->thread; in ThreadStartFunc()
99 int32_t ThreadIsSelf(const Thread *thread) in ThreadIsSelf()
109 static void ThreadStop(Thread *thread) in ThreadStop()
112 if (ThreadIsSelf((const Thread *)thread) == 0) { in ThreadStop()
123 Thread *ThreadCreate(const char *name) in ThreadCreate()
125 Thread *thread = (Thread *)callo in ThreadCreate()
[all...] |
| H A D | alarm_linux.c | 30 static Thread *g_alarmThread = NULL;
|
| /foundation/ai/ai_engine/services/common/platform/threadpool/include/ |
| H A D | thread.h | 30 class Thread;
112 void SetThread(Thread *thread) in SetThread()
122 Thread *thread_;
129 class Thread { class
134 Thread();
135 virtual ~Thread();
|
| H A D | thread_pool.h | 34 typedef std::list<std::shared_ptr<Thread>> Threads;
41 * get a Thread from thread pool
45 std::shared_ptr<Thread> Pop();
50 void Push(std::shared_ptr<Thread>& thread);
|
| /foundation/ai/ai_engine/test/common/threadpool/ |
| H A D | thread_pool_test.cpp | 125 Thread thread; in HWTEST_F()
139 Thread testThread; in HWTEST_F()
141 HILOGD("[Test]Thread id %lu.", id); in HWTEST_F()
146 HILOGD("[Test]Thread id %lu.", id); in HWTEST_F()
183 std::shared_ptr<Thread> oneThread = threadPool->Pop(); in HWTEST_F()
199 std::shared_ptr<Thread> oneThread = threadPool->Pop(); in HWTEST_F()
216 std::shared_ptr<Thread> threadList[maxThreadNum]; in HWTEST_F()
|
| /foundation/ai/ai_engine/services/server/server_executor/include/ |
| H A D | engine.h | 37 Engine(std::shared_ptr<Plugin> &plugin, std::shared_ptr<Thread> &thread, std::shared_ptr<Queue<Task>> &queue);
89 std::shared_ptr<Thread> thread_;
|
| /foundation/arkui/ui_lite/tools/server/ |
| H A D | tcp_server.py | 25 class TestServer(threading.Thread):
56 threading.Thread.__init__(self)
188 thread_recv = threading.Thread(target=self.tcp_connect, args=(conn, addr))
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.h | 28 Thread *BTM_GetProcessingThread();
|
| H A D | btm_thread.c | 40 static Thread *g_processingThread = NULL;
181 Thread *BTM_GetProcessingThread() in BTM_GetProcessingThread()
|
| /foundation/ai/ai_engine/services/server/communication_adapter/include/ |
| H A D | client_listener_handler.h | 33 * Thread class for listening async process result
85 std::shared_ptr<Thread> asyncProcessThread_ = nullptr;
|
| /foundation/ai/ai_engine/services/client/communication_adapter/include/ |
| H A D | sa_client_adapter.h | 150 std::shared_ptr<Thread> connectMgrThread_ = nullptr;
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine.cpp | 29 Engine::Engine(std::shared_ptr<Plugin> &plugin, std::shared_ptr<Thread> &thread, in Engine()
|
| H A D | engine_manager.cpp | 203 std::shared_ptr<Thread> thread = threadPool->Pop(); in CreateEngine()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/cmd/ |
| H A D | hci_cmd.c | 138 Thread *thread = BTM_GetProcessingThread(); in HciCmdOnCmdTimeout()
|