Package io.deephaven.engine.table.impl

Class ForkJoinPoolOperationInitializer

java.lang.Object

io.deephaven.engine.table.impl.ForkJoinPoolOperationInitializer

All Implemented Interfaces:

OperationInitializer

public class ForkJoinPoolOperationInitializer
extends Object
implements OperationInitializer

Implementation of OperationInitializer that delegates to a ForkJoinPool.

Field Summary

Fields inherited from interface io.deephaven.engine.updategraph.OperationInitializer

NON_PARALLELIZABLE

Method Summary

Modifier and Type	Method	Description
boolean	canParallelize()	Whether the current thread can parallelize operations using this OperationInitialization.
static Runnable	ensureParallelizable(@NotNull Runnable task)	Ensure that task is parallelizable within the current ExecutionContext, by wrapping it with a new ExecutionContext that uses fromCommonPool() if the current ExecutionContext does not allow parallelization.
static <T> Supplier<T>	ensureParallelizable(@NotNull Supplier<T> task)	Ensure that task is parallelizable within the current ExecutionContext, by wrapping it with a new ExecutionContext that uses fromCommonPool() if the current ExecutionContext does not allow parallelization.
static @NotNull OperationInitializer	fromCommonPool()
int	parallelismFactor()	Number of threads that are potentially available.
@NotNull Future<?>	submit(@NotNull Runnable taskRunnable)	Submits a task to run in this thread pool.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

fromCommonPool

@NotNull
public static @NotNull OperationInitializer fromCommonPool()

canParallelize

public boolean canParallelize()

Description copied from interface: OperationInitializer

Whether the current thread can parallelize operations using this OperationInitialization.

Specified by:

canParallelize in interface OperationInitializer

submit

@NotNull
public @NotNull Future<?> submit(@NotNull
 @NotNull Runnable taskRunnable)

Description copied from interface: OperationInitializer

Submits a task to run in this thread pool.

Specified by:

submit in interface OperationInitializer

parallelismFactor

public int parallelismFactor()

Description copied from interface: OperationInitializer

Number of threads that are potentially available.

Specified by:

parallelismFactor in interface OperationInitializer

ensureParallelizable

public static Runnable ensureParallelizable(@NotNull
 @NotNull Runnable task)

Ensure that task is parallelizable within the current ExecutionContext, by wrapping it with a new ExecutionContext that uses fromCommonPool() if the current ExecutionContext does not allow parallelization.

Parameters:

task - The task to possible wrap

Returns:

The possibly-wrapped task

ensureParallelizable

public static <T> Supplier<T> ensureParallelizable(@NotNull
 @NotNull Supplier<T> task)

Ensure that task is parallelizable within the current ExecutionContext, by wrapping it with a new ExecutionContext that uses fromCommonPool() if the current ExecutionContext does not allow parallelization.

Parameters:

task - The task to possible wrap

Returns:

The possibly-wrapped task