Package kilim

Class Mailbox.BlockingSubscriber

java.lang.Object
kilim.Mailbox.BlockingSubscriber
All Implemented Interfaces:
EventSubscriber
Enclosing class:
Mailbox<T>
public class Mailbox.BlockingSubscriber extends Object implements EventSubscriber

  • Field Details

    • eventRcvd

      public volatile boolean eventRcvd

    • current

      private long current

    • tom

      private long tom

    • start

      private long start

  • Constructor Details

    • BlockingSubscriber

      public BlockingSubscriber(long tom)

  • Method Details

    • onEvent

      public void onEvent(EventPublisher ep, Event e)
      Specified by:
      onEvent in interface EventSubscriber

    • blockingWait

      public boolean blockingWait()
      wait for either a timeout or event, returning true if the timeout occurred