Most visited

Recently visited

Results for

Added in API level 21

Summary: Ctors | Methods | Protected Methods | Inherited Methods | [Expand All]

RecursiveTask

public abstract class RecursiveTask
extends ForkJoinTask<V>

java.lang.Object
↳	java.util.concurrent.ForkJoinTask<V>
	↳	java.util.concurrent.RecursiveTask<V>

递归结果 - 方位 ForkJoinTask 。

举一个典型的例子，这是一个计算斐波那契数的任务：

 class Fibonacci extends RecursiveTask<Integer> {
   final int n;
   Fibonacci(int n) { this.n = n; }
   protected Integer compute() {
     if (n <= 1)
       return n;
     Fibonacci f1 = new Fibonacci(n - 1);
     f1.fork();
     Fibonacci f2 = new Fibonacci(n - 2);
     return f2.compute() + f1.join();
   }
 }

However, besides being a dumb way to compute Fibonacci functions (there is a simple fast linear algorithm that you'd use in practice), this is likely to perform poorly because the smallest subtasks are too small to be worthwhile splitting up. Instead, as is the case for nearly all fork/join applications, you'd pick some minimum granularity size (for example 10 here) for which you always sequentially solve rather than subdividing.

Summary

Public constructors
`RecursiveTask()`

Public methods
`final V`	`getRawResult()` 返回 `join()`返回的结果，即使此任务异常完成，或 `null`如果此任务未知完成）。

Protected methods
`abstract V`	`compute()` 此任务执行的主要计算。
`final boolean`	`exec()` 为RecursiveTask实现执行约定。
`final void`	`setRawResult(V value)` 因此强制返回给定的值。

Inherited methods

From class java.util.concurrent.ForkJoinTask

`static <T> ForkJoinTask<T>`	`adapt(Runnable runnable, T result)` 返回一个新的 `ForkJoinTask` ，它执行给定 `Runnable`的 `run`方法作为其操作，并将给定结果返回到 `join()` 。
`static ForkJoinTask<?>`	`adapt(Runnable runnable)` 返回一个新的 `ForkJoinTask` ，它执行给定 `Runnable`的 `run`方法作为其操作，并在 `join()`返回空结果。
`static <T> ForkJoinTask<T>`	`adapt(Callable<? extends T> callable)` 返回一个新的 `ForkJoinTask` ，该 `call`执行给定 `Callable`的 `call`方法作为其操作，并在 `join()`返回结果，将检测到的任何检查到的异常转换为 `RuntimeException` 。
`boolean`	`cancel(boolean mayInterruptIfRunning)` 试图取消执行此任务。
`final boolean`	`compareAndSetForkJoinTaskTag(short expect, short update)` 原子上有条件地设置此任务的标记值。
`void`	`complete(V value)` 完成此任务，如果尚未中止或取消，则返回给定值作为后续调用 `join`及相关操作的结果。
`void`	`completeExceptionally(Throwable ex)` 异常完成此任务，如果尚未中止或取消，则导致它在 `join`和相关操作中抛出给定异常。
`abstract boolean`	`exec()` 立即执行此任务的基本操作，并返回true，如果从此方法返回后，此任务保证已正常完成。
`final ForkJoinTask<V>`	`fork()` 安排在池异步执行这一任务，当前任务运行在（如果适用），或使用 `commonPool()`如果不是 `inForkJoinPool()` 。
`final V`	`get(long timeout, TimeUnit unit)` 如果需要，最多等待计算完成的给定时间，然后检索其结果（如果可用）。
`final V`	`get()` 如果需要，等待计算完成，然后检索其结果。
`final Throwable`	`getException()` 返回基本计算抛出的异常，或者 `CancellationException`如果取消），或者 `null`如果没有）或方法尚未完成。
`final short`	`getForkJoinTaskTag()` 返回此任务的标签。
`static ForkJoinPool`	`getPool()` 如果当前线程在任何ForkJoinPool外执行，则返回承载当前线程的池或 `null` 。
`static int`	`getQueuedTaskCount()` 返回当前工作线程已分叉但尚未执行的任务数的估计值。
`abstract V`	`getRawResult()` 返回 `join()`返回的结果，即使此任务异常完成，或 `null`如果此任务未知完成）。
`static int`	`getSurplusQueuedTaskCount()` 返回当前工作线程持有多少本地排队任务的估计值，而不是其他可能窃取它们的工作线程的值，如果此线程未在ForkJoinPool中运行，则返回零。
`static void`	`helpQuiesce()` 可能会执行任务，直到托管当前任务的池 is quiescent 。
`static boolean`	`inForkJoinPool()` 返回 `true`如果当前线程是 `ForkJoinWorkerThread`执行作为ForkJoinPool计算。
`final V`	`invoke()` 开始执行此任务，如果需要，等待其完成，然后返回其结果，或者如果基础计算 `Error`则抛出（未选中） `RuntimeException`或 `Error` 。
`static void`	`invokeAll(ForkJoinTask...<?> tasks)` `isDone`给定的任务，当每个任务保持 `isDone`或遇到（未经检查）的异常时返回，在这种情况下，异常被重新抛出。
`static void`	`invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2)` `isDone`给定任务，当每个任务保持 `isDone`或遇到（未经检查）的异常时返回，在这种情况下重新排除异常。
`static <T extends ForkJoinTask<?>> Collection<T>`	`invokeAll(Collection<T> tasks)` `isDone`指定集合中的所有任务，当每个任务保持 `isDone`或遇到（未检查）异常时返回，在这种情况下，将重新抛出异常。
`final boolean`	`isCancelled()` 如果此任务在正常完成之前取消，则返回 `true` 。
`final boolean`	`isCompletedAbnormally()` 如果此任务引发异常或被取消，则返回 `true` 。
`final boolean`	`isCompletedNormally()` 如果此任务完成而没有抛出异常并且未取消，则返回 `true` 。
`final boolean`	`isDone()` 如果此任务完成，则返回 `true` 。
`final V`	`join()` 返回 `is done`时的计算结果。
`static ForkJoinTask<?>`	`peekNextLocalTask()` 返回但不排除或执行由当前线程排队但尚未执行的任务（如果立即可用）。
`static ForkJoinTask<?>`	`pollNextLocalTask()` 如果当前线程正在ForkJoinPool中运行，那么取消调度并返回（不执行）下一个由当前线程排队但尚未执行的任务。
`static ForkJoinTask<?>`	`pollTask()` 如果当前线程正在ForkJoinPool中运行，则取消调度并返回（不执行）由当前线程排队但尚未执行的下一个任务（如果有）或者不可用时由其他线程分叉的任务，如果可供使用的话。
`final void`	`quietlyComplete()` 通常无需设置值即可完成此任务。
`final void`	`quietlyInvoke()` 开始执行此任务并在必要时等待完成，而不返回结果或抛出异常。
`final void`	`quietlyJoin()` 加入此任务，但不返回结果或抛出异常。
`void`	`reinitialize()` 重置此任务的内部簿记状态，允许随后 `fork` 。
`final short`	`setForkJoinTaskTag(short newValue)` 以原子方式设置此任务的标记值并返回旧值。
`abstract void`	`setRawResult(V value)` 因此强制返回给定的值。
`boolean`	`tryUnfork()` 试图排除这个任务的执行。

From class java.lang.Object

From interface java.util.concurrent.Future

Public constructors

RecursiveTask

Added in API level 21

RecursiveTask ()

Public methods

getRawResult

Added in API level 21

V getRawResult ()

返回join()返回的结果，即使此任务异常完成，或null如果此任务未知完成。此方法旨在帮助调试以及支持扩展。不鼓励在任何其他情况下使用它。

Returns
`V`	the result, or `null` if not completed

Protected methods

compute

Added in API level 21

V compute ()

此任务执行的主要计算。

Returns
`V`	the result of the computation

exec

Added in API level 21

boolean exec ()

为RecursiveTask实现执行约定。

Returns
`boolean`	`true` if this task is known to have completed normally

setRawResult

Added in API level 21

void setRawResult (V value)

因此强制返回给定的值。此方法旨在支持扩展，通常不应另行调用。

Parameters
`value`	`V`: the value

Interfaces

Classes

Enums

Exceptions

Most visited

Recently visited

Results for

RecursiveTask

Summary

Public constructors

Public methods

Protected methods

Inherited methods

Public constructors

RecursiveTask

Public methods

getRawResult

Protected methods

compute

exec

setRawResult