使用std::async编辑数组

#include <iostream>
#include <vector>
#include <future>

void processArray(std::vector<int>& arr, int start, int end) {
    for (int i = start; i < end; i++) {
        // 对数组元素进行处理
        arr[i] *= 2;
    }
}

int main() {
    std::vector<int> arr = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
    int numThreads = 4; // 假设使用4个线程并发处理数组

    int chunkSize = arr.size() / numThreads;
    std::vector<std::future<void>> futures;

    for (int i = 0; i < numThreads; i++) {
        int start = i * chunkSize;
        int end = (i == numThreads - 1) ? arr.size() : (i + 1) * chunkSize;
        futures.push_back(std::async(std::launch::async, processArray, std::ref(arr), start, end));
    }

    // 等待所有异步任务完成
    for (auto& future : futures) {
        future.wait();
    }

    // 输出处理后的数组
    for (int num : arr) {
        std::cout << num << " ";
    }
    std::cout << std::endl;

    return 0;
}