尝试使用生产者-消费者模型来模拟linux cat命令，但输出似乎显示了一行的多个副本

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

std::queue<std::string> buffer;  // 共享缓冲区
std::mutex mtx;  // 互斥锁
std::condition_variable cv;  // 条件变量
bool finished = false;  // 是否完成所有数据的读取

void producer(const std::string& filename) {
    std::ifstream file(filename);
    std::string line;

    while (std::getline(file, line)) {
        std::lock_guard<std::mutex> lock(mtx);
        buffer.push(line);
        cv.notify_one();  // 通知消费者有新数据可用
    }

    // 数据读取完成后设置标志位
    {
        std::lock_guard<std::mutex> lock(mtx);
        finished = true;
    }

    cv.notify_all();  // 通知所有消费者数据已读取完成
}

void consumer() {
    while (true) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, []{ return !buffer.empty() || finished; });

        while (!buffer.empty()) {
            std::string line = buffer.front();
            buffer.pop();

            std::cout << line << std::endl;
        }

        if (finished && buffer.empty()) {
            break;  // 所有数据已读取完成，退出循环
        }
    }
}

int main() {
    std::string filename = "input.txt";

    std::thread producerThread(producer, filename);
    std::thread consumerThread(consumer);

    producerThread.join();
    consumerThread.join();

    return 0;
}