Package jadex.future

Class FutureBlockingQueue<T>

java.lang.Object
jadex.future.FutureBlockingQueue<T>

public class FutureBlockingQueue<T> extends Object
  • Field Details

    • capacity

      protected int capacity
    • queue

      protected final Queue<T> queue
    • consumers

      protected final Queue<Future<T>> consumers
    • producers

      protected final Queue<Runnable> producers
  • Constructor Details

    • FutureBlockingQueue

      public FutureBlockingQueue(int capacity)
  • Method Details

    • enqueue

      public Future<Void> enqueue(T elem)
    • dequeue

      public Future<T> dequeue()
    • size

      public int size()