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 int
end
End positionprivate ArrayDBIDs
ids
Array IDs to processprivate Processor[]
procs
The processor masters that own the instances.private int
start
Start positionprivate java.util.HashMap<SharedVariable<?>,SharedVariable.Instance<?>>
variables
Variables map.
-
Constructor Summary
Constructors Modifier Constructor Description protected
BlockArrayRunner(ArrayDBIDs ids, int start, int end, Processor[] procs)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ArrayDBIDs
call()
<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:
call
in interfacejava.util.concurrent.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 interfaceExecutor
- Type Parameters:
I
- Variable type- Parameters:
parent
- Channel parent- Returns:
- Channel instance
-
-