summaryrefslogtreecommitdiff
path: root/src/components/include/utils/threads/message_loop_thread.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/components/include/utils/threads/message_loop_thread.h')
-rw-r--r--src/components/include/utils/threads/message_loop_thread.h4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/components/include/utils/threads/message_loop_thread.h b/src/components/include/utils/threads/message_loop_thread.h
index 26ae127b69..b1a6714be1 100644
--- a/src/components/include/utils/threads/message_loop_thread.h
+++ b/src/components/include/utils/threads/message_loop_thread.h
@@ -138,7 +138,7 @@ MessageLoopThread<Q>::MessageLoopThread(const std::string& name,
const ThreadOptions& thread_opts)
: thread_delegate_(new LoopThreadDelegate(&message_queue_, handler))
, thread_(threads::CreateThread(name.c_str(), thread_delegate_)) {
- const bool started = thread_->start(thread_opts);
+ const bool started = thread_->Start(thread_opts);
if (!started) {
CREATE_LOGGERPTR_LOCAL(logger_, "Utils")
LOG4CXX_ERROR(logger_, "Failed to start thread " << name);
@@ -159,7 +159,7 @@ void MessageLoopThread<Q>::PostMessage(const Message& message) {
template <class Q>
void MessageLoopThread<Q>::Shutdown() {
- thread_->join();
+ thread_->Stop(threads::Thread::kThreadStopDelegate);
}
template <class Q>