From 21c03d1956417384d4cecefbc6830d956b6b4af9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pedro=20J=2E=20Est=C3=A9banez?= Date: Thu, 13 Jun 2024 10:14:14 +0200 Subject: [PATCH] WorkerThreadPool: Fix thread message queue not restored after overridden in a task Also, simplifies the thread override teardown in MessageQueue. --- core/io/resource_loader.cpp | 1 + core/object/message_queue.cpp | 6 +----- core/object/worker_thread_pool.cpp | 3 +++ 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/core/io/resource_loader.cpp b/core/io/resource_loader.cpp index c3c37aa89d5..e557a36fc2a 100644 --- a/core/io/resource_loader.cpp +++ b/core/io/resource_loader.cpp @@ -395,6 +395,7 @@ void ResourceLoader::_thread_load_function(void *p_userdata) { if (load_nesting == 0) { if (mq_override) { + MessageQueue::set_thread_singleton_override(nullptr); memdelete(mq_override); } memdelete(load_paths_stack); diff --git a/core/object/message_queue.cpp b/core/object/message_queue.cpp index 762bab75e79..4b0b1ce63d8 100644 --- a/core/object/message_queue.cpp +++ b/core/object/message_queue.cpp @@ -481,10 +481,7 @@ CallQueue::~CallQueue() { if (!allocator_is_custom) { memdelete(allocator); } - // This is done here to avoid a circular dependency between the safety checks and the thread singleton pointer. - if (this == MessageQueue::thread_singleton) { - MessageQueue::thread_singleton = nullptr; - } + DEV_ASSERT(!is_current_thread_override); } ////////////////////// @@ -493,7 +490,6 @@ CallQueue *MessageQueue::main_singleton = nullptr; thread_local CallQueue *MessageQueue::thread_singleton = nullptr; void MessageQueue::set_thread_singleton_override(CallQueue *p_thread_singleton) { - DEV_ASSERT(p_thread_singleton); // To unset the thread singleton, don't call this with nullptr, but just memfree() it. #ifdef DEV_ENABLED if (thread_singleton) { thread_singleton->is_current_thread_override = false; diff --git a/core/object/worker_thread_pool.cpp b/core/object/worker_thread_pool.cpp index 9c9e0fa8991..a7c0a0353e6 100644 --- a/core/object/worker_thread_pool.cpp +++ b/core/object/worker_thread_pool.cpp @@ -53,7 +53,9 @@ void WorkerThreadPool::_process_task(Task *p_task) { int pool_thread_index = thread_ids[Thread::get_caller_id()]; ThreadData &curr_thread = threads[pool_thread_index]; Task *prev_task = nullptr; // In case this is recursively called. + bool safe_for_nodes_backup = is_current_thread_safe_for_nodes(); + CallQueue *call_queue_backup = MessageQueue::get_singleton() != MessageQueue::get_main_singleton() ? MessageQueue::get_singleton() : nullptr; { // Tasks must start with this unset. They are free to set-and-forget otherwise. @@ -169,6 +171,7 @@ void WorkerThreadPool::_process_task(Task *p_task) { } set_current_thread_safe_for_nodes(safe_for_nodes_backup); + MessageQueue::set_thread_singleton_override(call_queue_backup); #endif }