Interface Plugin.Engine.Dispatcher

All Superinterfaces:
AutoCloseable, Closeable
All Known Implementing Classes:
Plugin.Engine.Dispatcher.ForParallelTransformation, Plugin.Engine.Dispatcher.ForParallelTransformation.WithThrowawayExecutorService, Plugin.Engine.Dispatcher.ForSerialTransformation
Enclosing interface:
Plugin.Engine

public static interface Plugin.Engine.Dispatcher extends Closeable
A dispatcher to execute a plugin engine transformation. A dispatcher will receive all work assignments prior to the invocation of complete. After registering and eventually completing the supplied work, the close method will always be called. Any dispatcher will only be used once and from a single thread.
  • Method Details

    • accept

      void accept(Callable<? extends Callable<? extends Plugin.Engine.Dispatcher.Materializable>> work, boolean eager) throws IOException
      Accepts a new work assignment.
      Parameters:
      work - The work to handle prefixed by a preprocessing step.
      eager - true if the processing does not need to be deferred until all preprocessing is complete.
      Throws:
      IOException - If an I/O exception occurs.
    • complete

      void complete() throws IOException
      Completes the work being handled.
      Throws:
      IOException - If an I/O exception occurs.