Package elki.parallel

Class 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 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.
    • 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 java.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 interface Executor
        Type Parameters:
        I - Variable type
        Parameters:
        parent - Channel parent
        Returns:
        Channel instance