使用Boost Futex同步线程时线程始终无法唤醒的问题排查

你的代码存在几个关键问题，导致线程无法被唤醒：

1. 线程执行逻辑顺序错误 #

每个线程的逻辑是先调用wait再调用fpost，但初始状态下，第一个线程进入wait后会将futexp从1改为0，随后阻塞在futex_wait，根本无法走到fpost步骤。后续所有线程都会卡在wait的futex_wait调用上，没有线程能执行唤醒操作，最终导致所有线程死锁。

2. wait函数的循环逻辑错误 #

std::atomic_compare_exchange_strong的行为是：当原子变量当前值等于expected时，将其替换为desired并返回true；否则将expected更新为原子变量当前值并返回false。你的wait函数中，循环条件是交换成功时进入循环，这会导致第一个线程在成功将futexp从1改为0后，进入空循环体，然后再次尝试交换（此时expected还是1，而原子变量值是0，交换失败退出循环）——这部分逻辑冗余且容易混淆。

3. 未处理futex的虚假唤醒 #

futex_wait可能会因为*虚假唤醒（spurious wakeup）*返回，此时需要重新检查等待条件，否则线程会错误地继续执行。你的代码中没有这一步检查。

4. 使用Boost内部未公开API #

boost::fibers::detail::futex属于Boost的内部实现细节（detail命名空间），并非公开API，其行为可能在不同版本中变化，不建议直接使用。如果要使用futex，建议直接调用Linux系统调用，或者使用Boost提供的公开同步组件。

修复后的代码示例 #

以下是修正后的代码，实现类似信号量的同步逻辑，让线程依次执行：

#include <iostream>
#include <atomic>
#include <thread>
#include <vector>
#include <chrono>
#include <sys/syscall.h>
#include <unistd.h>

// 封装Linux futex系统调用，替代Boost内部API
inline int futex_wait(std::atomic<int>* futexp, int expected) {
    return syscall(SYS_futex, futexp, FUTEX_WAIT, expected, nullptr, nullptr, 0);
}

inline int futex_wake(std::atomic<int>* futexp, int count = 1) {
    return syscall(SYS_futex, futexp, FUTEX_WAKE, count, nullptr, nullptr, 0);
}

void wait(std::atomic<int>& futexp) {
    int expected = 1;
    // 循环检查条件，处理虚假唤醒
    while (!std::atomic_compare_exchange_strong(&futexp, &expected, 0)) {
        // 只有当当前值不是1时，才进入等待
        if (expected != 1) {
            futex_wait(&futexp, 0);
            // 等待唤醒后，重置expected为1，重新检查
            expected = 1;
        }
    }
    std::cout << std::this_thread::get_id() << ", " << futexp.load() << std::endl;
}

void post(std::atomic<int>& futexp) {
    int expected = 0;
    if (std::atomic_compare_exchange_strong(&futexp, &expected, 1)) {
        // 唤醒一个等待的线程
        futex_wake(&futexp);
    }
}

std::atomic<int> futexp{1};

int main() {
    std::vector<std::thread> vec;
    // 创建5个线程
    for(int i = 0; i < 5; ++i) {
        vec.emplace_back([&]() {
            wait(futexp);
            // 模拟线程工作
            std::this_thread::sleep_for(std::chrono::milliseconds(500));
            post(futexp);
        });
    }
    // 等待所有线程结束
    for(auto& el : vec) {
        el.join();
    }
    std::cout << "All threads finished" << std::endl;
}

修复说明 #

• 调整线程逻辑：确保每个线程在完成wait后能执行post，唤醒下一个线程。初始futexp为1，第一个线程能通过wait，执行完工作后post，将futexp设为1，唤醒下一个线程。
• 正确处理futex等待逻辑：在wait函数中，循环检查条件，处理虚假唤醒；只有当条件不满足时才进入等待。
• 使用Linux原生futex系统调用：避免依赖Boost内部未公开API，保证代码的稳定性。
• 添加模拟工作：让线程执行一些工作后再post，更贴近实际场景。

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