Класс RecursiveAction

public abstract class RecursiveAction
extends ForkJoinTask<Void>

Рекурсивное бессостоятельное ForkJoinTask. Этот класс устанавливает соглашения для параметризации бессостоятельных действий как Void ForkJoinTask. Поскольку null — единственное допустимое значение типа Void, методы, такие как join, всегда возвращают null по завершении.

Примеры использования. Вот простой, но полный сортировочный ForkJoin, который сортирует заданный long[] массив:

static class SortTask extends RecursiveAction {
   final long[] array; final int lo, hi;
   SortTask(long[] array, int lo, int hi) {
     this.array = array; this.lo = lo; this.hi = hi;
   }
   SortTask(long[] array) { this(array, 0, array.length); }
   protected void compute() {
     if (hi - lo < THRESHOLD)
       sortSequentially(lo, hi);
     else {
       int mid = (lo + hi) >>> 1;
       invokeAll(new SortTask(array, lo, mid),
                 new SortTask(array, mid, hi));
       merge(lo, mid, hi);
     }
   }
   // implementation details follow:
   static final int THRESHOLD = 1000;
   void sortSequentially(int lo, int hi) {
     Arrays.sort(array, lo, hi);
   }
   void merge(int lo, int mid, int hi) {
     long[] buf = Arrays.copyOfRange(array, lo, mid);
     for (int i = 0, j = lo, k = mid; i < buf.length; j++)
       array[j] = (k == hi || buf[i] < array[k]) ?
         buf[i++] : array[k++];
   }
 }

Вы затем можете отсортировать anArray, создав new SortTask(anArray) и вызвав его в ForkJoinPool. Как более конкретный простой пример, следующая задача увеличивает каждый элемент массива:

class IncrementTask extends RecursiveAction {
   final long[] array; final int lo, hi;
   IncrementTask(long[] array, int lo, int hi) {
     this.array = array; this.lo = lo; this.hi = hi;
   }
   protected void compute() {
     if (hi - lo < THRESHOLD) {
       for (int i = lo; i < hi; ++i)
         array[i]++;
     }
     else {
       int mid = (lo + hi) >>> 1;
       invokeAll(new IncrementTask(array, lo, mid),
                 new IncrementTask(array, mid, hi));
     }
   }
 }

Следующий пример иллюстрирует некоторые усовершенствования и идиомы, которые могут привести к лучшей производительности: RecursiveActions необязательно должны быть полностью рекурсивными, если они сохраняют базовый подход «разделяй и властвуй». Вот класс, который суммирует квадраты каждого элемента массива double, деля только правую часть при многократном делении на два и отслеживая их с помощью цепочки next ссылок. Он использует динамический порог, основанный на методе getSurplusQueuedTaskCount, но компенсирует потенциальное чрезмерное разбиение, непосредственно выполняя действия на листах для неворованных задач, а не дальнейшим разделением.

double sumOfSquares(ForkJoinPool pool, double[] array) {
   int n = array.length;
   Applyer a = new Applyer(array, 0, n, null);
   pool.invoke(a);
   return a.result;
 }

 class Applyer extends RecursiveAction {
   final double[] array;
   final int lo, hi;
   double result;
   Applyer next; // keeps track of right-hand-side tasks
   Applyer(double[] array, int lo, int hi, Applyer next) {
     this.array = array; this.lo = lo; this.hi = hi;
     this.next = next;
   }

   double atLeaf(int l, int h) {
     double sum = 0;
     for (int i = l; i < h; ++i) // perform leftmost base step
       sum += array[i] * array[i];
     return sum;
   }

   protected void compute() {
     int l = lo;
     int h = hi;
     Applyer right = null;
     while (h - l > 1 && getSurplusQueuedTaskCount() <= 3) {
       int mid = (l + h) >>> 1;
       right = new Applyer(array, mid, h, right);
       right.fork();
       h = mid;
     }
     double sum = atLeaf(l, h);
     while (right != null) {
       if (right.tryUnfork()) // directly calculate if not stolen
         sum += right.atLeaf(right.lo, right.hi);
       else {
         right.join();
         sum += right.result;
       }
       right = right.next;
     }
     result = sum;
   }
 }

Конструкторы

RecursiveAction

public RecursiveAction()

Методы

compute

protected abstract void compute()

Основное вычисление, выполняемое этой задачей.

getRawResult

public final Void getRawResult()

Всегда возвращает null.

Задано:

getRawResult в классе ForkJoinTask<Void>

Возвращает:

null всегда

setRawResult

protected final void setRawResult(Void mustBeNull)

Требует значение завершения null.

Задано:

setRawResult в классе ForkJoinTask<Void>

Параметры:

mustBeNull - значение

exec

protected final boolean exec()

Реализует соглашения об выполнении для RecursiveActions.

Задано:

exec в классе ForkJoinTask<Void>

Возвращает:

true если известно, что эта задача завершилась нормально