Class QueuedConsumer<T>

java.lang.Object
org.ojalgo.type.function.QueuedConsumer<T>
All Implemented Interfaces:
AutoCloseable, Consumer<T>, AutoConsumer<T>, AutoFunctional

final class QueuedConsumer<T> extends Object implements AutoConsumer<T>
  • Field Details

    • myActive

      private volatile boolean myActive
    • myBatchSize

      private final int myBatchSize
    • myConsumers

      private final Consumer<T>[] myConsumers
    • myFutures

      private final Future<?>[] myFutures
    • myQueue

      private final BlockingQueue<T> myQueue
  • Constructor Details

  • Method Details

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface AutoConsumer<T>
      Throws:
      Exception
    • write

      public void write(T item)
      Description copied from interface: AutoConsumer
      Write the item to the consumer.
      Specified by:
      write in interface AutoConsumer<T>
      Parameters:
      item - The item to be written
    • drainTo

      int drainTo(List<T> batchContainer)
    • isMoreToCome

      boolean isMoreToCome()
    • newBatchContainer

      List<T> newBatchContainer()