Назад к вопросам
Junior — Middle
65
Какими методами можно реализовать параллельный подсчёт суммы элементов массива при помощи ForkJoinPool?
Ответ от нейросети
sobes.tech AI
Для параллельного подсчёта суммы элементов массива с помощью ForkJoinPool можно реализовать рекурсивную задачу, которая делит массив на части и суммирует их параллельно.
Основная идея:
- Если размер подмассива небольшой, считаем сумму напрямую.
- Иначе делим подмассив на две части, создаём две подзадачи, запускаем их параллельно и объединяем результаты.
Пример на Java с использованием RecursiveTask<Integer>:
import java.util.concurrent.*;
public class SumTask extends RecursiveTask<Integer> {
private static final int THRESHOLD = 1000;
private int[] array;
private int start, end;
public SumTask(int[] array, int start, int end) {
this.array = array;
this.start = start;
this.end = end;
}
@Override
protected Integer compute() {
int length = end - start;
if (length <= THRESHOLD) {
int sum = 0;
for (int i = start; i < end; i++) {
sum += array[i];
}
return sum;
} else {
int mid = start + length / 2;
SumTask leftTask = new SumTask(array, start, mid);
SumTask rightTask = new SumTask(array, mid, end);
leftTask.fork(); // запускаем левую задачу асинхронно
int rightResult = rightTask.compute(); // вычисляем правую задачу в текущем потоке
int leftResult = leftTask.join(); // ждём результат левой задачи
return leftResult + rightResult;
}
}
}
// Использование:
// ForkJoinPool pool = new ForkJoinPool();
// int[] data = ...;
// int totalSum = pool.invoke(new SumTask(data, 0, data.length));
Такой подход эффективно использует многопоточность для ускорения подсчёта суммы большого массива.