C++服务优雅退出：自定义sleep与条件变量实现详解

系统sleep导致的退出延迟问题

在常规C++服务逻辑中，通常使用sleep让线程周期性执行任务。但当用户按下Ctrl+C发送SIGINT中断信号时，若此时线程正处于系统休眠状态，程序虽能捕捉信号并设置退出标记，但仍需等待sleep结束才会彻底退出。这种非预期的等待在长耗时场景下尤为明显。

第1步：重现标准sleep的退出延迟

目的：观察系统级休眠导致的信号处理延迟。 代码实现：

/* filename: test.cpp */
#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
#include <signal.h>

class TestServer {
public:
    TestServer() : run_(true) {}
    void Start() { pthread_create(&thread_, NULL, ThreadProc, (void*)this); }
    void Stop() { run_ = false; }
    void Wait() { pthread_join(thread_, NULL); }
    void Proc() {
        while (run_) {
            printf("sleep count:%d\n", ++count);
            sleep(5);
        }
    }
private:
    bool run_;
    pthread_t thread_;
    static void* ThreadProc(void* arg) {
        TestServer* me = static_cast<TestServer*>(arg);
        me->Proc();
        return NULL;
    }
};

编译运行：使用g++ test.cpp -o test -lpthread编译后运行。按下Ctrl+C时，观察终端输出发现程序并未立即退止，而是继续打印直到当前的5秒周期结束。

方案一：自定义微秒级循环sleep

该方法的核心思路是将单次长时间休眠分割为多个极短的usleep调用，每次短暂休眠后检查退出标志位。虽然无法做到“瞬间”退出，但能将最大延迟压缩至单次休眠间隔（本例为0.1秒）。

第1步：实现带标志位检测的自定义sleep

参数说明： - seconds: 期望总休眠时间（秒）。 - *run: 指向布尔型退出标志的指针，实时读取其值。

class TestServer {
    // ... 其他成员保持不变 ...
    private: 
    void sleep(int seconds, const bool* run) {
        int count = seconds * 10; // 分割为10个周期
        while (*run && count > 0)
        {
            --count;
            usleep(100000); // 每100ms检测一次
        }
    }
};;

修改主循环：在Proc函数中将原有的sleep(5)替换为成员函数调用sleep(5, &run_)。 完成判断：编译运行后按Ctrl+C，程序会在最迟0.1秒内响应并退出。

方案二：基于条件变量的高效休眠

使用POSIX线程库中的互斥锁与条件变量，可实现更精准的定时唤醒与外部即时唤醒。pthread_cond_timedwait允许线程阻塞等待指定绝对时间，但若收到pthread_cond_signal信号则可提前返回。

第1步：初始化互斥锁与条件变量

入口：类的构造函数与析构函数。 动作：分别调用pthread_mutex_init与pthread_cond_init。

class TestServer {
public:
    TestServer() : run_(true) {
        pthread_mutex_init(&mutex_, NULL);
        pthread_cond_init(&cond_, NULL);
    }
    ~TestServer() {
        pthread_mutex_destroy(&mutex_);
        pthread_cond_destroy(&cond_);
    }
private:
    bool run_;
    pthread_mutex_t mutex_;
    pthread_cond_t cond_;
    // ...

第2步：编写带超时的等待逻辑

目的：在循环中释放锁并阻塞等待指定时长，或被外部信号触发唤醒。 关键步骤：

1. 使用gettimeofday获取当前时间。
2. 计算目标绝对时间outtime（当前时间+5秒）。
3. 加锁并调用pthread_cond_timedwait。

void Proc() {
    pthread_mutex_lock(&mutex_);
    struct timeval now;
    int count = 0;
    while (run_) {
        printf("sleep count:%d\n", ++count);
        gettimeofday(&now, NULL);
        struct timespec outtime;
        outtime.tv_sec = now.tv_sec + 5;
        outtime.tv_nsec = now.tv_usec * 1000;
        // 核心休眠调用，此处会阻塞直至超时或被signal唤醒
        pthread_cond_timedwait(&cond_, &mutex_, &outtime);
    }
    pthread_mutex_unlock(&mutex_);
}

第3步：实现即时唤醒机制

目的：在停止服务时，强制唤醒正在等待的线程。 动作：在修改run_ = false后，通过锁保护直接触发条件变量。

void Stop() {
    run_ = false;
    pthread_mutex_lock(&mutex_);
    pthread_cond_signal(&cond_); // 触发一个等待线程
    pthread_mutex_unlock(&mutex_);
}

结果验证：使用该完整逻辑编译运行，按下Ctrl+C后，Stop函数将立刻发出信号，Proc函数跳出while(run_)循环并解锁返回，从而实现近乎无延迟的服务关停。