std::notify_all_at_thread_exit

void notify_all_at_thread_exit( std::condition_variable& cond,
                                std::unique_lock<std::mutex> lk );

notify_all_at_thread_exit предоставляет механизм для уведомления других потоков о полном завершении данного потока, включая уничтожение всех объектов thread_local. Он работает следующим образом:

• Владение ранее полученным замком lk передается в внутреннее хранилище.
• Среда выполнения изменяется таким образом, что при выходе текущего потока, переменная состояния cond уведомляется как если бы это делалось:

lk.unlock();cond.notify_all();

Подразумеваемое lk.unlock() происходит после (как определено в std::memory_order) уничтожения всех объектов с временем жизни thread local, связанных с текущим потоком.

Аналогичный эффект можно достичь с помощью средств, предоставляемых std::promise или std::packaged_task.

Примечания

Вызов этой функции, если lock.mutex() не заблокирован текущим потоком, является неопределенным поведением.

Вызов этой функции, если lock.mutex() не совпадает с мьютексом, используемым всеми другими потоками, которые в настоящее время ожидают той же переменной состояния, является неопределенным поведением.

Предоставленный замок lk удерживается до выхода потока. После вызова этой функции, больше ни один поток не может получить тот же замок для ожидания cond. Если некоторые потоки ожидают этой переменной состояния, убедитесь, что ожидаемое условие выполняется при удержании замка на lk, и что этот замок не освобождается и не перезахватывается до вызова notify_all_at_thread_exit для предотвращения путаницы из-за ложных пробуждений в других потоках.

В типичных случаях использования эта функция является последним вызовом в отсоединённом потоке.

Параметры

Возвращаемое значение

(нет)

Пример

#include <cassert>
#include <condition_variable>
#include <mutex>
#include <string>
#include <thread>
 
std::mutex m;
std::condition_variable cv;
 
bool ready = false;
std::string result; // some arbitrary type
 
void thread_func()
{
    thread_local std::string thread_local_data = "42";
 
    std::unique_lock<std::mutex> lk(m);
 
    // assign a value to result using thread_local data
    result = thread_local_data;
    ready = true;
 
    std::notify_all_at_thread_exit(cv, std::move(lk));
 
}   // 1. destroy thread_locals;
    // 2. unlock mutex;
    // 3. notify cv.
 
int main()
{
    std::thread t(thread_func);
    t.detach();
 
    // do other work
    // ...
 
    // wait for the detached thread
    std::unique_lock<std::mutex> lk(m);
    cv.wait(lk, []{ return ready; });
 
    // result is ready and thread_local destructors have finished, no UB
    assert(result == "42");
}

См. также