如何在java中并行化for循环？

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class ParallelForLoop {
    public static void main(String[] args) {
        int[] array = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
        int numThreads = Runtime.getRuntime().availableProcessors(); // 获取处理器数量
        ExecutorService executor = Executors.newFixedThreadPool(numThreads); // 创建线程池

        int chunkSize = array.length / numThreads; // 每个子任务处理的数组元素数量
        int startIndex = 0;

        // 创建并提交子任务
        Future<Integer>[] futures = new Future[numThreads];
        for (int i = 0; i < numThreads; i++) {
            int endIndex = startIndex + chunkSize;
            if (i == numThreads - 1) {
                endIndex = array.length; // 最后一个子任务处理剩余的元素
            }
            futures[i] = executor.submit(new SquareTask(array, startIndex, endIndex));
            startIndex = endIndex;
        }

        // 等待所有子任务完成
        executor.shutdown();
        while (!executor.isTerminated()) {
            // 等待线程池中的所有任务执行完毕
        }

        // 合并子任务的结果
        int result = 0;
        for (Future<Integer> future : futures) {
            try {
                result += future.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        System.out.println("Result: " + result);
    }
}

class SquareTask implements Callable<Integer> {
    private int[] array;
    private int startIndex;
    private int endIndex;

    public SquareTask(int[] array, int startIndex, int endIndex) {
        this.array = array;
        this.startIndex = startIndex;
        this.endIndex = endIndex;
    }

    @Override
    public Integer call() throws Exception {
        int sum = 0;
        for (int i = startIndex; i < endIndex; i++) {
            sum += array[i] * array[i];
        }
        return sum;
    }
}