当join()期间可能收到中断信号（SIGINT）时，如何安全处理线程join操作？

兄弟，这个坑我之前做服务端多线程程序的时候实打实踩过！当时主程序正卡在join()等工作线程退出，手滑按了Ctrl+C，结果直接死锁，查了大半天才捋清楚问题根源：信号处理函数里直接操作线程、调用join()是绝对的禁区，而且主流程已经在join了，信号里再瞎操作，简直是给程序埋炸弹。

我给你捋一套稳得一批的解决方案，都是实战验证过的：

1. 信号处理只做「最小操作」，别搞花活 #

首先，信号处理函数的执行上下文特别特殊，只能调用异步信号安全的函数（比如原子变量赋值、write到管道这些），像std::thread::join()、std::cout、malloc这些全是雷区，碰都别碰。

所以信号处理函数里只干一件事：把全局的原子退出标志位设为true，如果需要通知主程序，就用「自管道技巧」写个字节到管道（write是异步安全的），别搞别的：

#include <signal.h>
#include <atomic>
#include <unistd.h>

std::atomic<bool> g_should_shutdown{false};
int g_shutdown_pipe[2];

void sigint_handler(int signum) {
    if (signum == SIGINT && !g_should_shutdown) {
        g_should_shutdown = true;
        // 写个字节到管道，通知主程序处理后续逻辑
        char dummy = 'x';
        write(g_shutdown_pipe[1], &dummy, 1);
    }
}

2. 让工作线程「主动退休」，别硬杀 #

千万别用pthread_cancel这种强制终止线程的骚操作，这会导致线程在执行到一半被砍死，锁没释放、文件没关闭、内存没回收，分分钟死锁或者内存泄漏。

正确的做法是让工作线程定期检查退出标志位，主动收尾退出：

• 如果是循环执行任务的线程，每次循环开头或者任务间隙查一下标志位：

  void worker_task() {
      while (!g_should_shutdown) {
          // 执行你的业务任务
          // ...
      }
      // 退出前乖乖清理资源：释放锁、关闭文件、释放内存
      clean_up_resources();
  }
  

• 如果线程里有阻塞操作（比如等条件变量、等网络数据），别用无限阻塞，改用带超时的方法，或者配合自管道的通知：比如用wait_for代替wait，或者主程序收到管道通知后，唤醒所有等待的条件变量，让线程能及时醒来检查标志位。

3. 主程序处理join的中断，反复尝试 #

当主程序在调用join()时收到SIGINT，底层的pthread_join会被信号中断，返回EINTR错误，C++里会抛出std::system_error异常。这时候你不能直接放弃，要重新调用join()，直到线程真正退出。

主程序的join逻辑大概是这样：

#include <thread>
#include <vector>
#include <system_error>
#include <fcntl.h>

int main() {
    // 初始化自管道
    if (pipe(g_shutdown_pipe) == -1) {
        // 处理管道初始化错误
        return 1;
    }
    // 把管道读端设为非阻塞（可选，看你要不要同时处理其他事件）
    fcntl(g_shutdown_pipe[0], F_SETFL, O_NONBLOCK);

    // 注册SIGINT信号处理函数
    signal(SIGINT, sigint_handler);

    // 启动工作线程
    std::vector<std::thread> workers;
    for (int i = 0; i < 4; ++i) {
        workers.emplace_back(worker_task);
    }

    // 处理join，捕获中断异常并重试
    for (auto& worker : workers) {
        while (true) {
            try {
                worker.join();
                break; // join成功，换下一个线程
            } catch (const std::system_error& e) {
                if (e.code().value() == EINTR) {
                    // 被信号中断了，继续等，线程已经在退出路上了
                    continue;
                } else {
                    // 其他错误，比如线程已经被join过了，直接抛出
                    throw;
                }
            }
        }
    }

    // 关闭管道
    close(g_shutdown_pipe[0]);
    close(g_shutdown_pipe[1]);
    return 0;
}

最后再划几个红线： #

• 信号处理函数里绝对不能调用std::thread::join()、std::cout、malloc这些非异步安全函数
• 绝对不要强制终止线程，一定要让线程主动退出
• 退出标志位必须是原子的，或者用互斥锁保护（但原子变量更高效，而且异步安全）

备注：内容来源于stack exchange，提问作者Ilan Noy