Package elki.parallel
Class ParallelExecutor.BlockArrayRunner
- java.lang.Object
-
- elki.parallel.ParallelExecutor.BlockArrayRunner
-
- All Implemented Interfaces:
Executor,java.util.concurrent.Callable<ArrayDBIDs>
- Enclosing class:
- ParallelExecutor
protected static class ParallelExecutor.BlockArrayRunner extends java.lang.Object implements java.util.concurrent.Callable<ArrayDBIDs>, Executor
Run for an array part, without step size.- Author:
- Erich Schubert
-
-
Field Summary
Fields Modifier and Type Field Description private intendEnd positionprivate ArrayDBIDsidsArray IDs to processprivate Processor[]procsThe processor masters that own the instances.private intstartStart positionprivate java.util.HashMap<SharedVariable<?>,SharedVariable.Instance<?>>variablesVariables map.
-
Constructor Summary
Constructors Modifier Constructor Description protectedBlockArrayRunner(ArrayDBIDs ids, int start, int end, Processor[] procs)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ArrayDBIDscall()<I extends SharedVariable.Instance<?>>
IgetInstance(SharedVariable<I> parent)Get a channel for this executor.
-
-
-
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 java.util.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 processstart- Starting positionend- End positionprocs- Processors to run
-
-
Method Detail
-
call
public ArrayDBIDs call()
- Specified by:
callin interfacejava.util.concurrent.Callable<ArrayDBIDs>
-
getInstance
public <I extends SharedVariable.Instance<?>> I getInstance(SharedVariable<I> parent)
Description copied from interface:ExecutorGet a channel for this executor.- Specified by:
getInstancein interfaceExecutor- Type Parameters:
I- Variable type- Parameters:
parent- Channel parent- Returns:
- Channel instance
-
-