多线程C++消息传递

#include<iostream>
#include<thread>
#include <mutex>
#include<queue>

std::mutex mtx;
std::queue<int> messages;

void send_message(int msg) {
    std::unique_lock<std::mutex> lock(mtx);
    messages.push(msg);
    lock.unlock();
}

int receive_message() {
    std::unique_lock<std::mutex> lock(mtx);
    while (messages.empty()) {
        lock.unlock();
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
        lock.lock();
    }
    int msg = messages.front();
    messages.pop();
    lock.unlock();
    return msg;
}

void thread_func() {
    for (int i = 0; i < 10; ++i) {
        send_message(i);
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }
}

int main() {
    std::thread t(thread_func);
    for (int i = 0; i < 10; ++i) {
        int msg = receive_message();
        std::cout << "Received message: "<< msg<< std::endl;
    }
    t.join();
    return 0;
}