线程函数未执行问题排查：疑似存在竞态条件

嘿，我一眼就看到问题所在了——你明明定义了std::condition_variable和std::mutex用来做线程同步，结果完全没用到，反而用了一个低效又容易出问题的忙等循环，这就是线程看起来没执行的核心原因！

核心问题拆解 #

• 你的cpu_show_answer函数里的while (check == false) { }是忙等循环：哪怕其他线程把check设为true，由于CPU缓存的存在，当前线程可能迟迟看不到这个更新（虽然你用了std::atomic<bool>，理论上有内存可见性，但忙等本身就是个糟糕的同步方式）。
• 条件变量和 mutex 被闲置了，这本来是用来优雅实现线程等待/通知的工具，结果没派上用场，自然容易出现竞态或线程挂起的情况。

修正后的代码示例 #

我把你的代码改成正确使用条件变量的写法，同时补全cpu_parallel_search的逻辑，确保线程间同步正常：

#include <iostream>
#include <vector>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <atomic>

std::condition_variable waitforme;
std::mutex block;
std::atomic<bool> check = false;

void cpu_show_answer(std::vector<int>& v1, const std::vector<std::string>& v2) {
    // 用条件变量替代忙等，高效等待通知
    std::unique_lock<std::mutex> lock(block);
    // 等待直到check为true，自动处理锁的释放与重新获取
    waitforme.wait(lock, []{ return check.load(); });

    for (int i = 0; i < v1.size(); i++) {
        // 注意：v1是int容器，NULL是指针常量，用-1作为无效索引更合理
        if (v1[i] != -1) { 
            std::cout << "Found your word: " << v2[v1[i]] << " at index " << v1[i] + 1 << std::endl;
        }
    }
}

// 补全cpu_parallel_search的逻辑，完成后通知等待线程
void cpu_parallel_search(const int begin, const int end, std::string search_term, std::vector<int>& result) {
    // 模拟并行搜索过程
    for (int i = begin; i < end; ++i) {
        // 这里替换成你的实际搜索逻辑，找到匹配项就加入result
        if (search_term == v2[i]) { // 假设v2是全局或通过参数传递的目标字符串容器
            result.push_back(i);
        }
    }

    // 搜索完成后，设置标志并通知等待线程
    check.store(true);
    waitforme.notify_one(); // 唤醒等待的cpu_show_answer线程
}

int main() {
    std::vector<int> search_result;
    std::vector<std::string> target_words = {"apple", "banana", "cherry", "date"};

    // 注意用std::ref传递容器引用，避免拷贝
    std::thread search_thread(cpu_parallel_search, 0, target_words.size(), "banana", std::ref(search_result));
    std::thread show_thread(cpu_show_answer, std::ref(search_result), std::cref(target_words));

    search_thread.join();
    show_thread.join();

    return 0;
}

关键修正点解释 #

1. 替换忙等为条件变量：waitforme.wait(lock, []{ return check.load(); })会让线程进入休眠状态，直到其他线程调用notify_one()，且check为true时才唤醒，既节省CPU资源，又避免了内存可见性问题。
2. mutex与条件变量配对使用：条件变量必须和mutex配合，unique_lock会自动管理锁的生命周期，等待期间释放锁，唤醒后重新获取锁，确保线程安全。
3. 修复类型不匹配问题：原代码中v1[i] != NULL是错误的，v1是int容器，应该用-1这类适合int的无效值判断是否找到匹配项。
4. 正确传递线程参数：用std::ref/std::cref传递容器引用，避免线程操作容器的副本，保证数据同步。

额外注意事项 #

• 如果有多个等待线程，要使用notify_all()而非notify_one()。
• 确保cpu_parallel_search在完全完成搜索任务后再设置check并通知，避免cpu_show_answer处理不完整的结果数据。

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