Class IterativeWorkerTaskFactory<T>

  • All Implemented Interfaces:

    public abstract class IterativeWorkerTaskFactory<T>extends Objectimplements ExecutorServices.TaskFactory<Void>
    Used for decomposition of loops in which independent tasks are processed sequentially. Based on the size of a thread pool, the factory creates an equal number of workers. Each worker iterates on a shared concurrent queue. The queue is created from the source items (iterable).
    Jozef Hartinger
    • Constructor Detail

      • IterativeWorkerTaskFactory

        public IterativeWorkerTaskFactory(Iterable<? extends T> iterable)
    • Method Detail

      • init

        protected void init()
        Called before the compilation begins.
      • cleanup

        protected void cleanup()
        Called after the computation finishes.
      • doWork

        protected abstract void doWork(T item)
      • getQueue

        public Queue<T> getQueue()

Copyright © 2015. All Rights Reserved.

Add the Maven Dependecy to your project: maven dependecy for com.amazonaws : aws-java-sdk : 1.3.14