在C++线程池中打印重复的编号

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

std::queue<int> taskQueue; // 任务队列
std::mutex mtx; // 互斥锁，用于保护任务队列的访问
std::condition_variable cv; // 条件变量，用于线程间的同步

// 任务函数
void taskFunction()
{
    while (true)
    {
        std::unique_lock<std::mutex> lock(mtx);
        // 等待任务队列不为空
        cv.wait(lock, [] { return !taskQueue.empty(); });

        // 从任务队列中获取任务
        int task = taskQueue.front();
        taskQueue.pop();

        // 执行任务
        std::cout << "编号：" << task << std::endl;

        lock.unlock();
        cv.notify_all();
    }
}

int main()
{
    const int numThreads = 4; // 线程池中的线程数量

    // 创建线程池中的线程
    std::vector<std::thread> threads;
    for (int i = 0; i < numThreads; ++i)
    {
        threads.emplace_back(taskFunction);
    }

    // 添加任务到任务队列
    for (int i = 1; i <= 10; ++i)
    {
        std::lock_guard<std::mutex> lock(mtx);
        taskQueue.push(i);
    }

    cv.notify_all();

    // 等待所有线程执行完毕
    for (auto& thread : threads)
    {
        thread.join();
    }

    return 0;
}