de.lmu.ifi.dbs.elki.parallel

Class SingleThreadedExecutor.SingleThreadedRunner

java.lang.Object

de.lmu.ifi.dbs.elki.parallel.SingleThreadedExecutor.SingleThreadedRunner

All Implemented Interfaces:

Executor

Enclosing class:

SingleThreadedExecutor

protected static class SingleThreadedExecutor.SingleThreadedRunner
extends Object
implements Executor

Run for an array part, without step size.

Author:

Erich Schubert

Field Summary

Fields

Modifier and Type	Field and Description
private DBIDs	ids Array IDs to process
private Processor[]	procs The process masters that own the instances.
private HashMap<SharedVariable<?>,SharedVariable.Instance<?>>	variables Variables map.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SingleThreadedExecutor.SingleThreadedRunner(DBIDs ids, Processor[] procs) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
<I extends SharedVariable.Instance<?>> I	getInstance(SharedVariable<I> parent) Get a channel for this executor.
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

ids

private DBIDs ids

Array IDs to process

procs

private Processor[] procs

The process masters that own the instances.

variables

private HashMap<SharedVariable<?>,SharedVariable.Instance<?>> variables

Variables map.

Constructor Detail

SingleThreadedExecutor.SingleThreadedRunner

protected SingleThreadedExecutor.SingleThreadedRunner(DBIDs ids,
                                           Processor[] procs)

Constructor.

Parameters:

ids - IDs to process

procs - Processor functions to run

Method Detail

run

public void run()

getInstance

public <I extends SharedVariable.Instance<?>> I getInstance(SharedVariable<I> parent)

Description copied from interface: Executor

Get a channel for this executor.

Specified by:

getInstance in interface Executor

Type Parameters:

I - Variable type

Parameters:

parent - Channel parent

Returns:

Channel instance