Class FanIn.InputBunch

  • Enclosing class:
    FanIn

    public abstract static class FanIn.InputBunch
    extends java.lang.Object
    • Constructor Detail

      • InputBunch

        public InputBunch​(int inputCount,
                          int bufferSize,
                          Pump pump)
    • Method Detail

      • AllOfMarkedInputs

        public java.lang.Object AllOfMarkedInputs()
      • AnyOfMarkedInputs

        public java.lang.Object AnyOfMarkedInputs()
      • cancel

        public void cancel()
      • cancel

        public void cancel​(int input)
      • dequeue

        public java.lang.Object dequeue​(int id)
      • dequeueAndYield

        public java.lang.Object dequeueAndYield()
      • dequeueAndYield

        public java.lang.Object dequeueAndYield​(int id)
      • dequeuePreferring

        public java.lang.Object dequeuePreferring​(int preferred)
      • idToDequeue

        public int idToDequeue()
      • inputsAvailableFor

        public java.lang.Object inputsAvailableFor​(int id)
      • inputsOrCompleteAvailableFor

        public java.lang.Object inputsOrCompleteAvailableFor​(int id)
      • isAllCompleted

        public boolean isAllCompleted()
      • isCancelled

        public boolean isCancelled​(int input)
      • isDepleted

        public boolean isDepleted​(int input)
      • isPending

        public boolean isPending​(int input)
      • lastDequeuedId

        public int lastDequeuedId()
      • markAllInputs

        public void markAllInputs()
      • markInput

        public void markInput​(int input)
      • onCompleteWhenNoInput

        public void onCompleteWhenNoInput()
      • onDepleted

        public void onDepleted​(int input)
      • onError

        public abstract void onError​(int input,
                                     java.lang.Throwable e)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • unmarkAllInputs

        public void unmarkAllInputs()
      • unmarkInput

        public void unmarkInput​(int input)