std:: notify_all_at_thread_exit

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

• Владение ранее полученной блокировкой lk передается во внутреннее хранилище.

• Среда выполнения модифицируется таким образом, что при завершении текущего потока условная переменная cond уведомляется как если бы было выполнено lk. unlock ( ) ;
  cond. notify_all ( ) ; .

Подразумеваемый lk. unlock ( ) выполняется после упорядочивания разрушения всех объектов с продолжительностью хранения в локальной памяти потока , связанных с текущим потоком.

Если выполняется любое из следующих условий, поведение не определено:

• lk не заблокирован вызывающим потоком.
• Если другие потоки также ожидают на cond , lk. mutex ( ) отличается от мьютекса, разблокированного функциями ожидания ( wait , wait_for и wait_until ), вызванными на cond этими потоками.

Примечания

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

Предоставленная блокировка 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");
}

Отчеты о дефектах

Следующие отчеты об изменениях поведения, влияющие на дефекты, были применены ретроактивно к ранее опубликованным стандартам C++.

Смотрите также