C++多线程入门：小型案例

模拟线程通信

使用队列模拟两个线程间的通信，根据之前所学，提供一个线程基类，同时提供一个Msg派生类。
为了方便编写，将声明与定义写在一起。

线程基类

命名为BaseThread.hpp：

#pragma once
#include <thread>

class BaseThread
{
public:
	BaseThread():bExit(false)
    {

    }

	virtual void ThreadStart()
    {
        bExit = false;
	    th = std::thread(&BaseThread::Main,this);
    }

	virtual void ThreadStop()
    {
        bExit=true;
        Wait();
    }

	// 等待线程退出-阻塞式
	virtual void Wait()
    {
        if (th.joinable()) {
            th.join();
        }
    }

	bool GetIsExit() { return bExit; }

	virtual ~BaseThread()
    {

    }

private:
	// 逻辑入口
	virtual void Main() = 0;

	bool bExit;
	std::thread th;
};

提供Msg派生类

同样声明为MsgServer.hpp：

#pragma once
#include "BaseThread.h"
#include <string>
#include <queue>
#include <mutex>
#include <iostream>
class MsgServer : public BaseThread
{
public:
	MsgServer():MaxQueneLength(20),CurrentLength(0)
    {

    }

	// 给当前线程发送消息,在主线程中访问
	void SendMsg(std::string Msg)
    {
        using namespace std;
        unique_lock<mutex> Lock(Mtx);
        // 也可以使用一个缓冲区来来临时存放数据
        if (CurrentLength >= MaxQueueLength) {
            return;
        }
        MsgQueue.push(Msg);
        CurrentLength++;
    }
private:
	virtual void Main() override
    {
        using namespace std;
        cout << "Start" << endl;
        while (!GetIsExit()) {
            // 处理最大延时
            this_thread::sleep_for(100ms);
            unique_lock<mutex> lock(Mtx);
            if (MsgQueue.empty()) {
                continue;
            }
            while (!MsgQueue.empty()){
                cout << "RecvMsg = " << MsgQueue.front() << endl;
                MsgQueue.pop();
                CurrentLength--;
            }
	    }
    }

	// 设置消息队列
	std::queue<std::string> MsgQueue;

	std::mutex Mtx;

	size_t MaxQueueLength;
	size_t CurrentLength;
};

进行测试

#include "MsgServer.hpp"
#include <sstream>
using namespace std;
int main()
{
	MsgServer msgServer;
	msgServer.ThreadStart();
	/*for (int i = 0; i < 15; i++) {
		std::stringstream ss;
		ss << "MsgId = " << i;
		msgServer.SendMsg(ss.str());
		this_thread::sleep_for(100ms);
	}*/
	while (true)
	{
		string s;
		cin >> s;
		if (s == "exit") {
			break;
		}

		msgServer.SendMsg(s);
	}
	msgServer.ThreadStop();
	system("pause");
}

• 本文作者： KongXinQing
• 本文链接： https://13114987559.github.io/2024/03/29/note/C++多线程入门：小型案例/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！