C++中能否强制std::condition_variable::notify_one通知特定线程？

标准库的std::condition_variable只能通过notify_one()随机唤醒一个等待的线程，或者用notify_all()唤醒所有等待线程，没法直接指定唤醒某个特定线程（比如最近创建的）。要实现这个需求，你需要为每个线程单独配备一个条件变量，通过容器管理这些条件变量来精准控制唤醒目标。

具体实现思路 #

1. 为每个线程创建独立的std::condition_variable和对应的唤醒标志、互斥锁，用结构体封装这些组件。
2. 用容器（比如std::deque）存储所有线程的信号组件，最近创建的线程的信号放在容器尾部，方便快速获取。
3. 需要唤醒最近创建的线程时，直接取出容器尾部的信号组件，设置唤醒标志并调用其条件变量的notify_one()。

代码示例 #

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <deque>
#include <memory>
#include <chrono>

// 封装每个线程的唤醒信号
struct ThreadSignal {
    std::mutex mtx;
    std::condition_variable cv;
    bool need_wakeup = false;
};

std::deque<std::unique_ptr<ThreadSignal>> thread_signals;
std::mutex signals_mutex; // 保护thread_signals容器的互斥锁

void worker_thread(ThreadSignal* signal) {
    std::unique_lock<std::mutex> lock(signal->mtx);
    // 等待唤醒信号
    signal->cv.wait(lock, [signal]() { return signal->need_wakeup; });
    
    // 被唤醒后执行任务（替换为你的业务逻辑）
    std::cout << "Worker thread " << std::this_thread::get_id() << " has been awakened\n";
    
    // 重置唤醒标志，支持后续再次唤醒
    signal->need_wakeup = false;
}

int main() {
    // 循环创建线程
    for (int i = 0; i < 10; ++i) {
        auto signal = std::make_unique<ThreadSignal>();
        {
            std::lock_guard<std::mutex> lock(signals_mutex);
            thread_signals.push_back(std::move(signal));
        }
        // 启动线程并绑定对应的信号
        std::thread(worker_thread, thread_signals.back().get()).detach();
        std::cout << "Created thread " << i + 1 << "\n";
    }

    // 通知最近创建的线程
    {
        std::lock_guard<std::mutex> lock(signals_mutex);
        if (!thread_signals.empty()) {
            auto& last_signal = thread_signals.back();
            std::lock_guard<std::mutex> signal_lock(last_signal->mtx);
            last_signal->need_wakeup = true;
            last_signal->cv.notify_one();
            std::cout << "Notified the most recently created thread\n";
        }
    }

    // 等待线程执行完成（实际场景按需处理线程生命周期）
    std::this_thread::sleep_for(std::chrono::seconds(2));

    return 0;
}

注意事项 #

• 线程结束后，要从thread_signals容器中移除对应的ThreadSignal对象，避免后续操作访问无效指针。
• 对thread_signals容器的所有访问必须加互斥锁，防止并发读写引发数据竞争。
• 若线程需要多次被唤醒，每次唤醒后必须重置need_wakeup标志位，避免误触发。
• 如果线程使用join()而非detach()，需妥善管理线程对象的生命周期，避免悬空指针。

内容的提问来源于stack exchange，提问作者KWL