Package de.uni_trier.wi2.procake.utils.concurrent

Interface ParallelPoolProcessing.ProcessingTask

Enclosing class:
ParallelPoolProcessing
public static interface ParallelPoolProcessing.ProcessingTask
Interface that holds the main method for every call to process an element from the case base.
Author:
Maximilian Hoffmann

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    process(DataObject[] elements, int iteration)
    This method is concurrently called by the workers for each case in the case base.

  • Method Details

    • process

      void process(DataObject[] elements, int iteration)
      This method is concurrently called by the workers for each case in the case base. Please make sure that every interaction of this method with other objects is synchronized. See an example implementation in ParallelLinearRetrieverImpl.
      Parameters:
      elements - a batch of cases from the case base to process
      iteration - the iteration number of the current call, starting from 0