C++多线程chap2多线程通信和同步9

这里，只是记录自己的学习笔记。

顺便和大家分享多线程的基础知识。然后从入门到实战。有代码。

知识点来源：

https://edu.51cto.com/course/26869.html

---

条件变量应用线程通信解决线程退出时的阻塞问题

这里是重构了前面的一个工程。

xthread.h

#pragma once
#include <thread>

class XThread
{
public:
    //启动线程
    virtual void Start();

    //设置线程退出标志  并等待
    virtual void Stop();

    //等待线程退出（阻塞）
    virtual void Wait();

    //线程是否退出
    bool is_exit();

protected:
    bool is_exit_ = false;

private:
    //线程入口
    virtual void Main() = 0;

    std::thread th_;
};

xthread.cpp

#include "xthread.h"

using namespace std;


//启动线程
void XThread::Start() {
    is_exit_ = false;
    th_ = thread(&XThread::Main, this);
}

//设置线程退出标志  并等待
void XThread::Stop() {
    is_exit_ = true;
    Wait();
}

//等待线程退出（阻塞）
void XThread::Wait() {
    if (th_.joinable()) {
        th_.join();
    }
}

//线程是否退出
bool XThread::is_exit() {
    return is_exit_;
}

xmsg_server.h

#pragma once
#include "xthread.h"
#include <string>
#include <list>
#include <mutex>
class XMsgServer:public XThread
{
public:
    //给当前线程发消息
    void SendMsg(std::string msg);
    void Stop() override;
private:
    //处理消息的线程入口函数
    void Main()  override;

    //可以考虑给消息队列设置一个最大值，超过最大值就阻塞，或者发送失败等等
    //消息队列缓冲
    std::list<std::string> msgs_;

    //互斥访问消息队列
    std::mutex mux_;

    std::condition_variable cv_;
};

//使用互斥锁 + list 模拟 线程通信
//1.封装线程基类 XThread 控制线程启动和停止
//2.模拟消息服务器线程，接收字符串消息，并模拟处理
//3.通过 unique_lock 和 mutex 互斥访问 list<string> 消息队列 
//4.主线程定时发送消息给子线程
//

xmsg_server.cpp

重写了Stop函数

#include "xmsg_server.h"
#include <iostream>
using namespace std;
using namespace this_thread;

void XMsgServer::Stop() {
    is_exit_ = true;
    cv_.notify_all();
    Wait();
}

//给当前线程发消息
void XMsgServer::SendMsg(std::string msg) {
    unique_lock<mutex> lock(mux_);
    msgs_.push_back(msg);

    lock.unlock();
    cv_.notify_one();
}


    //处理消息的线程入口函数
void XMsgServer::Main() {
    while(!is_exit()) {
        unique_lock<mutex> lock(mux_);
        cv_.wait(lock, [this] {
            cout << "wait cv" << endl;
            if (is_exit()) return true; //处理退出逻辑
            return !msgs_.empty();
        });

        while (!msgs_.empty()) {
            //消息处理业务逻辑
            cout << "recv : " << msgs_.front() << endl;
            msgs_.pop_front();
        }
    }
}

hello.cpp

#include <iostream>
#include <string>
#include <mutex>
#include <thread>
#include "xmsg_server.h"
#include <sstream>
using namespace std;

int main()
{
    XMsgServer  server;
    server.Start();
    for (int i = 0; i < 10; i++) {
        stringstream ss;
        ss << " msg : " << i + 1;
        server.SendMsg(ss.str());
        this_thread::sleep_for(500ms);
    }

    server.Stop();
    cout << "Server stoped!" << endl;
    return 0;
}