在C++中使用两个线程分别处理同一终端窗口上的I/O

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

std::mutex mtx;
std::queue<std::string> messages;
std::condition_variable cv;

void input_thread() {
    std::string input;
    while (true) {
        std::getline(std::cin, input);
        std::unique_lock<std::mutex> lock(mtx);
        messages.push(input);
        cv.notify_one();
    }
}

void output_thread() {
    while (true) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, [] { return !messages.empty(); });
        std::string message = messages.front();
        messages.pop();
        lock.unlock();

        std::cout << "Output: " << message << std::endl;
    }
}

int main() {
    std::thread in_thread(input_thread);
    std::thread out_thread(output_thread);

    in_thread.join();
    out_thread.join();

    return 0;
}