You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@lens.apache.org by "Lavkesh Lahngir (JIRA)" <ji...@apache.org> on 2016/08/29 10:54:20 UTC

[jira] [Created] (LENS-1298) Thread should have ability to wait for Events to be processed

Lavkesh Lahngir created LENS-1298:
-------------------------------------

             Summary: Thread should have ability to wait for Events to be processed
                 Key: LENS-1298
                 URL: https://issues.apache.org/jira/browse/LENS-1298
             Project: Apache Lens
          Issue Type: New Feature
            Reporter: Lavkesh Lahngir
            Assignee: Lavkesh Lahngir


When a thread notifies event service to process any event, it should have a way to wait for it to be finished.
{code}
LensEvent event = new LensEvent();
synchronized(event) {
   eventservice.notifyEvent(event);
   event.wait();
}
{code}
The EventHandler will do a notifyall() on the event it is done handling. 
{code}
public void run() {
      try {
        Class<? extends LensEvent> evtClass = event.getClass();
        // Call listeners directly listening for this event type
        handleEvent(eventListeners.get(evtClass), event);
        Class<?> superClass = evtClass.getSuperclass();

        // Call listeners which listen of super types of this event type
        while (LensEvent.class.isAssignableFrom(superClass)) {
          if (eventListeners.containsKey(superClass)) {
            handleEvent(eventListeners.get(superClass), event);
          }
          superClass = superClass.getSuperclass();
        }
      } finally {
        synchronized (event) {
          event.notifyAll();
        }
      }
    }
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)