如何在while循环中搭配条件变量与互斥锁，使循环运行到shutdown被调用

核心问题定位 #

你的代码之所以一进入循环就阻塞，是逻辑顺序完全错了：

• 你将需要循环执行的业务逻辑放在了CV.wait()调用之前、持有锁的区间内，但紧接着就调用了条件变量等待，谓词要求doStop_为true才会退出等待，这就导致第一次进入循环拿到锁后，直接进入阻塞状态，根本不会运行业务代码。
• 互斥锁持有区间不合理，整个循环体都持有锁会导致shutDown拿锁被阻塞，也会严重影响并发性能。
• 要注意doStop_的线程可见性，未做同步保护的跨线程变量访问会出现未定义行为。

修复方案 #

根据你的实际业务场景，可以选择以下两种实现：

场景1：需要持续无间隔循环执行业务逻辑，直到停止信号触发 #

这种场景不需要使用条件变量，直接将doStop_定义为std::atomic<bool>即可，实现最简单：

// 类定义中修改doStop_的类型为std::atomic<bool>
void Server::runForever ()
{
    while(!doStop_.load(std::memory_order_acquire))
    {
        // 这里放你要循环执行的业务逻辑
        //Do something
    }
}

void Server::shutDown()
{
    doStop_.store(true, std::memory_order_release);
}

场景2：闲时阻塞等待，有任务时处理，收到停止信号直接退出 #

如果你的业务是事件驱动的，不需要空跑循环占用CPU，那条件变量的谓词要覆盖停止和有任务两个场景：

void Server::runForever ()
{
    while(true)
    {
        std::unique_lock<std::mutex> lck(stop);
        // 等待条件：要停止 或者 有待处理任务
        CV.wait(lck, [this]() {return doStop_ || !taskQueue.empty();});
        if (doStop_)
        {
            break;
        }
        // 取出任务后提前释放锁，执行业务逻辑时不要持有锁
        auto task = std::move(taskQueue.front());
        taskQueue.pop();
        lck.unlock();
        // 执行任务逻辑
        task();
    }
}

void Server::shutDown()
{
    std::scoped_lock lck(stop);
    doStop_ = true;
    CV.notify_one();
}

注意事项 #

• 跨线程访问的标志位建议优先用std::atomic类型，避免手动管理锁的同步遗漏问题。
• 条件变量的wait必须配合谓词使用，规避虚假唤醒导致的逻辑异常。
• 尽量缩小互斥锁的持有区间，仅在操作共享变量的时候持有锁，减少性能损耗。

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