Java中的线程-N个数的总和

import java.util.concurrent.*;

public class SumCalculator implements Callable<Integer> {
    private int[] nums;
    private int start;
    private int end;

    public SumCalculator(int[] nums, int start, int end) {
        this.nums = nums;
        this.start = start;
        this.end = end;
    }

    @Override
    public Integer call() {
        int sum = 0;
        for (int i = start; i <= end; i++) {
            sum += nums[i];
        }
        return sum;
    }

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        int[] nums = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};
        int threadCount = 4; // 假设使用4个线程计算

        ExecutorService executorService = Executors.newFixedThreadPool(threadCount);
        Future<Integer>[] futures = new Future[threadCount];

        int step = nums.length / threadCount;
        for (int i = 0; i < threadCount; i++) {
            int start = i * step;
            int end = (i == threadCount - 1) ? nums.length - 1 : (i + 1) * step - 1;
            futures[i] = executorService.submit(new SumCalculator(nums, start, end));
        }

        int totalSum = 0;
        for (int i = 0; i < threadCount; i++) {
            totalSum += futures[i].get();
        }

        executorService.shutdown();

        System.out.println("Total sum: " + totalSum);
    }
}