Module io.jenetics.base

Package io.jenetics.internal.util

Class Concurrency

java.lang.Object

io.jenetics.internal.util.Concurrency

All Implemented Interfaces:

AutoCloseable, Executor

public abstract class Concurrency
extends Object
implements Executor, AutoCloseable

Since:

2.0

Version:

3.8

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CORES
static final Concurrency	SERIAL_EXECUTOR

Constructor Summary

Constructors

Constructor	Description
Concurrency()

Method Summary

Modifier and Type	Method	Description
abstract void	close()
abstract void	execute(Seq<? extends Runnable> runnables)
Executor	getInnerExecutor()	Return the underlying Executor, which is used for performing the actual task execution.
static Concurrency	with(Executor executor)	Return a new Concurrency object from the given executor.
static Concurrency	withCommonPool()	Return a new Concurrency object using the common ForkJoinPool.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

Field Details

CORES

public static final int CORES

SERIAL_EXECUTOR

public static final Concurrency SERIAL_EXECUTOR

Constructor Details

Concurrency

public Concurrency()

Method Details

execute

public abstract void execute(Seq<? extends Runnable> runnables)

close

public abstract void close()

Specified by:

close in interface AutoCloseable

getInnerExecutor

public Executor getInnerExecutor()

Return the underlying Executor, which is used for performing the actual task execution.

Returns:

the underlying Executor object

with

public static Concurrency with(Executor executor)

Return a new Concurrency object from the given executor.

Parameters:

executor - the underlying Executor

Returns:

a new Concurrency object

withCommonPool

public static Concurrency withCommonPool()

Return a new Concurrency object using the common ForkJoinPool.

Returns:

a new Concurrency object using the new ForkJoinPool