de.lmu.ifi.dbs.elki.parallel

Class ParallelCore

java.lang.Object

de.lmu.ifi.dbs.elki.parallel.ParallelCore

public class ParallelCore
extends java.lang.Object

Core for parallel processing in ELKI, based on ThreadPoolExecutor.

TODO: make configurable how many threads are used.

Since:

0.7.0

Author:

Erich Schubert

Field Summary

Fields

Modifier and Type	Field and Description
static int	ALL_PROCESSORS The number of CPUs to use.
private int	connected Number of connected submitters.
private java.util.concurrent.ThreadPoolExecutor	executor Executor service.
private int	processors Maximum number of processors to use.
private static ParallelCore	STATIC Static core

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ParallelCore(int processors) Constructor.

Method Summary

Modifier and Type	Method and Description
void	connect() Connect to the executor.
void	disconnect() Disconnect to the executor.
static ParallelCore	getCore() Get the static core object.
int	getParallelism() Get desired level of parallelism
<T> java.util.concurrent.Future<T>	submit(java.util.concurrent.Callable<T> task) Submit a task to the executor core.

Methods inherited from class java.lang.Object

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

Field Detail

ALL_PROCESSORS

public static final int ALL_PROCESSORS

The number of CPUs to use.

STATIC

private static final ParallelCore STATIC

Static core

executor

private volatile java.util.concurrent.ThreadPoolExecutor executor

Executor service.

connected

private volatile int connected

Number of connected submitters.

processors

private int processors

Maximum number of processors to use.

Constructor Detail

ParallelCore

protected ParallelCore(int processors)

Constructor.

Method Detail

getCore

public static ParallelCore getCore()

Get the static core object.

Returns:

Core

getParallelism

public int getParallelism()

Get desired level of parallelism

Returns:

Number of threads to run in parallel

submit

public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)

Submit a task to the executor core.

Parameters:

task - Submitted task

Returns:

Future to observe completion

connect

public void connect()

Connect to the executor.

disconnect

public void disconnect()

Disconnect to the executor.