de.lmu.ifi.dbs.elki.parallel

Class ParallelCore

java.lang.Object

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

public class ParallelCore
extends Object

Core for parallel processing in ELKI, based on ThreadPoolExecutor. TODO: make configurable how many threads are used.

Author:

Erich Schubert

Field Summary

Fields

Modifier and Type	Field and Description
static int	ALL_PROCESSORS The number of CPUs to use.
private AtomicInteger	connected Number of connected submitters.
(package private) 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

Methods

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> Future<T>	submit(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

ThreadPoolExecutor executor

Executor service.

connected

private AtomicInteger 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> Future<T> submit(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.