Package com.github.workerframework.api

Interface BulkWorker

public interface BulkWorker
This interface should be implemented by CAF Workers which are able to process multiple tasks together. It is expected to be implemented by the WorkerFactory object which has been supplied by the getWorkerFactory() method of the WorkerFactoryProvider class.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    processTasks(BulkWorkerRuntime runtime)
    The Worker should begin processing the tasks.

  • Method Details

    • processTasks

      void processTasks(BulkWorkerRuntime runtime) throws InterruptedException
      The Worker should begin processing the tasks. It can use the runtime object to retrieve the tasks.
      Parameters:
      runtime - is used to retrieve the tasks
      Throws:
      InterruptedException - if the thread is interrupted by another thread