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.h12
1 files changed, 6 insertions, 6 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..6dea86696b 100644
--- a/src/components/include/utils/threads/message_loop_thread.h
+++ b/src/components/include/utils/threads/message_loop_thread.h
@@ -132,16 +132,17 @@ size_t MessageLoopThread<Q>::GetMessageQueueSize() const {
return message_queue_.size();
}
+SDL_CREATE_LOG_VARIABLE("Utils")
+
template <class Q>
MessageLoopThread<Q>::MessageLoopThread(const std::string& name,
Handler* handler,
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);
+ SDL_LOG_ERROR("Failed to start thread " << name);
}
}
@@ -159,7 +160,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>
@@ -178,8 +179,7 @@ MessageLoopThread<Q>::LoopThreadDelegate::LoopThreadDelegate(
template <class Q>
void MessageLoopThread<Q>::LoopThreadDelegate::threadMain() {
- CREATE_LOGGERPTR_LOCAL(logger_, "Utils")
- LOG4CXX_AUTO_TRACE(logger_);
+ SDL_LOG_AUTO_TRACE();
while (!message_queue_.IsShuttingDown()) {
DrainQue();
message_queue_.wait();