C++多线程chap2多线程通信和同步7_一个例子

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

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

知识点来源：

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

---

使用互斥锁 + list 模拟 线程通信

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

XThread 线程基类

xthread.h  文件 

#pragma once
#include <thread>

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

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

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

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

private:
    //线程入口
    virtual void Main() = 0;
    bool is_exit_ = false;
    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_;
}

XMsgServer 消息基类

xmsg_server.h 文件

#pragma once
#include "xthread.h"
#include <string>
#include <list>
#include <mutex>
class XMsgServer:public XThread
{
public:
    //给当前线程发消息
    void SendMsg(std::string msg);

private:
    //处理消息的线程入口函数
    void Main()  override;

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

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

xmsg_server.cpp 文件

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

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


    //处理消息的线程入口函数
void XMsgServer::Main() {
    while(!is_exit()) {
        sleep_for(10ms);
        unique_lock<mutex> lock(mux_);
        if (msgs_.empty())
            continue;
        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();
    return 0;
}