Home
last modified time | relevance | path

Searched refs:worker_ (Results 1 - 14 of 14) sorted by relevance

/foundation/ai/ai_engine/services/common/platform/threadpool/source/
H A Dthread.cpp42 : running_(false), status_(STOPPED), stackSize_(THREAD_DEFAULT_STACK_SIZE), worker_(nullptr) in Thread()
49 CHK_RET_NONE(worker_ == nullptr); in ~Thread()
51 worker_->SetThread(nullptr); in ~Thread()
52 worker_ = nullptr; in ~Thread()
67 return worker_; in GetWorker()
72 if (worker_ != nullptr) { in SetWorker()
73 worker_->SetThread(nullptr); in SetWorker()
76 worker_ = pWorker; in SetWorker()
89 if (worker_ != nullptr && worker_ in StartThread()
[all...]
/foundation/multimedia/av_codec/services/engine/codec/audio/
H A Daudio_codec_adapter.cpp34 if (worker_) { in ~AudioCodecAdapter()
35 worker_->Release(); in ~AudioCodecAdapter()
36 worker_.reset(); in ~AudioCodecAdapter()
37 worker_ = nullptr; in ~AudioCodecAdapter()
179 if (worker_) { in Reset()
180 worker_->Release(); in Reset()
181 worker_.reset(); in Reset()
182 worker_ = nullptr; in Reset()
269 auto result = worker_->GetInputBufferInfo(index); in QueueInputBuffer()
295 worker_ in QueueInputBuffer()
[all...]
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/timer/core/
H A Dtimer_core.cpp50 if (worker_.joinable()) { in ~TimerCore()
51 worker_.join(); in ~TimerCore()
63 worker_ = std::thread([this, threadName]() { TimerLoop(threadName); }); in Initialize()
64 SetThreadName(worker_.native_handle(), threadName); in Initialize()
65 SetThreadPriority(worker_.native_handle(), PRIORITY_NORMAL); in Initialize()
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dengine.cpp36 worker_(*queue) in Engine()
90 bool isStarted = thread_->StartThread(&worker_); in Initialize()
/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dengine.h92 EngineWorker worker_; member in OHOS::AI::Engine
/foundation/ai/ai_engine/services/common/platform/threadpool/include/
H A Dthread.h197 IWorker *worker_; member in OHOS::AI::Thread
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/timer/core/
H A Dtimer_core.h53 std::thread worker_{};
/foundation/multimodalinput/input/intention/cooperate/plugin/src/
H A Dcooperate.cpp315 worker_ = std::thread([this] { this->Loop(); }); in StartWorker()
328 if (worker_.joinable()) { in StopWorker()
329 worker_.join(); in StopWorker()
/foundation/multimedia/av_codec/services/engine/codec/include/audio/
H A Daudio_codec_adapter.h62 std::shared_ptr<AudioCodecWorker> worker_; member in OHOS::MediaAVCodec::AudioCodecAdapter
/foundation/multimodalinput/input/intention/cooperate/plugin/include/
H A Dcooperate.h68 std::thread worker_; member in OHOS::Msdp::DeviceStatus::Cooperate::final
/foundation/multimedia/media_foundation/video_processing_engine/framework/capi/video_processing/
H A Dvideo_processing_native.cpp55 worker_ = std::thread([this]() { in Initialize()
101 if (worker_.joinable()) { in Deinitialize()
102 worker_.join(); in Deinitialize()
/foundation/multimodalinput/input/intention/services/test/unittest/src/
H A Ddevice_manager_test.cpp343 worker_ = std::thread(std::bind(&ContextService::OnThread, this)); in OnStart()
365 if (worker_.joinable()) { in OnStop()
366 worker_.join(); in OnStop()
/foundation/multimodalinput/input/intention/services/test/unittest/include/
H A Ddevice_manager_test.h93 std::thread worker_; member in OHOS::Msdp::DeviceStatus::final
/foundation/multimedia/media_foundation/video_processing_engine/framework/capi/video_processing/include/
H A Dvideo_processing_native.h135 std::thread worker_{};

Completed in 6 milliseconds