대기 스레드는 이벤트

Question

상황을 잡는다 :

public void makeCall() { 
    Call call = CallFactory.createCall(); 
    CallListener listener = new CallListener(); 
    call.addListener(listener); 
    call.connect(); 
} 

:

@Transactional 
public void createCall() { 
    callManager.makeCall(); 
} 

하는의 그 콜 매니저는 다음과 같은 방법을 포함 가정 해 봅시다 : 나는 예를 들어 무효 방법, 를 실행 트랜잭션 방법을 가지고 connect() 메서드가 예외를 throw하지 않으면 makeCall() 메서드가 성공적으로 완료됩니다.

이제 리스너에서 우리는 예를 들어, 핸들러 방법이 있습니다

public void callTalking(AnyEvent event) { 
    //some logic 
} 

주요 질문은 : 우리의 거래 방법 createCall() 리스너까지이 callTalking에서 이벤트를 잡는다를 개최 할 수있는 아름다운 방법이() 시간 제한을 사용하지 않고?

편집 중요 정보는, 내가 (곧 말) gigaspace 폴링 이벤트를 사용하고 있음을 영원히 성공적인 거래 후 데이터베이스에서 오브젝트를합니다.

Answer 1

이것은 동기화를위한 예제 로직입니다. 스레드에서 실행되는 경우 영원히 차단됩니다. 이 예에서는 Call이 작동하는 스레드가 이벤트를 처리하지 않는 동안 주 스레드가 차단됩니다.

public void makeCall() { 
    Object semafor = new Object(); 
    synchronized (semafor) { 
     try { 
      CallListener listener = new CallListener() { 
       @Override 
       public void callTalking(AnyEvent event) { 
        // some logic 

        synchronized (semafor) { 
         semafor.notify(); 
        } 
       } 
      }; 

      Call call = CallFactory.createCall(); 
      call.addListener(listener); 
      call.connect(); 

      semafor.wait(); 
     } 
     catch (InterruptedException e) { 
      Thread.currentThread().interrupt(); 
      e.printStackTrace(); 
     } 
    } 
}