C++动态拆分线程工作的例程

#include <iostream>
#include <vector>
#include <thread>
#include <numeric>

// 假设这是我们需要并行处理的任务
void process_chunk(int start, int end) {
    for (int i = start; i <= end; ++i) {
        // 执行一些计算密集型工作
        std::cout << "Processing "<< i << " on thread " << std::this_thread::get_id() << std::endl;
    }
}

int main() {
    const int total_tasks = 100; // 总任务数
    const int num_threads = std::thread::hardware_concurrency(); // 获取硬件支持的并发线程数
    std::vector<std::thread> threads;

    // 计算每个线程处理的任务数量
    int tasks_per_thread = total_tasks / num_threads;
    int remaining_tasks = total_tasks % num_threads;

    int start = 0;
    for (int i = 0; i < num_threads; ++i) {
        int end = start + tasks_per_thread - 1;
        if (remaining_tasks > 0) {
            --remaining_tasks;
            ++end;
        }
        threads.emplace_back(process_chunk, start, end);
        start = end + 1;
    }

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

    std::cout << "All tasks completed." << std::endl;
    return 0;
}