de.lmu.ifi.dbs.elki.parallel

Class ParallelExecutor.BlockArrayRunner

java.lang.Object

de.lmu.ifi.dbs.elki.parallel.ParallelExecutor.BlockArrayRunner

All Implemented Interfaces:

Executor, Callable<ArrayDBIDs>

Enclosing class:

ParallelExecutor

protected static class ParallelExecutor.BlockArrayRunner
extends Object
implements Callable<ArrayDBIDs>, Executor

Run for an array part, without step size.

Author:

Erich Schubert

Field Summary

Fields

Modifier and Type	Field and Description
private int	end End position
private ArrayDBIDs	ids Array IDs to process
private Processor[]	procs The processor masters that own the instances.
private int	start Start position
private HashMap<SharedVariable<?>,SharedVariable.Instance<?>>	variables Variables map.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BlockArrayRunner(ArrayDBIDs ids, int start, int end, Processor[] procs) Constructor.

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

ids

private ArrayDBIDs ids

Array IDs to process

start

private int start

Start position

end

private int end

End position

procs

private Processor[] procs

The processor masters that own the instances.

variables

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

Variables map.

Constructor Detail

BlockArrayRunner

protected BlockArrayRunner(ArrayDBIDs ids,
                           int start,
                           int end,
                           Processor[] procs)

Constructor.

Parameters:

ids - IDs to process

start - Starting position

end - End position

procs - Processors to run

Method Detail

call

public ArrayDBIDs call()

Specified by:

call in interface Callable<ArrayDBIDs>

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