마침내 try-finally에서 마침내 스레드가 완료 될 때까지 기다리는 방법?

Question

저는 Swing 기반 데스크톱 응용 프로그램에서 JPA를 사용하고 있습니다. 내가 거래를 필요로하는 모든 방법이 try - catch - finally을 사용하고

public Object methodA() { 

    EntityManager em = emf.createEntityManager(); 
    em.getTransaction().begin(); 
    boolean hasError = false; 

    try { 
     SwingUtilities.invokeLater(new Runnable() { 
      public void run() { 
       // JPA operation does not work here 
       // because transaction has been committed! 
      } 
     }); 
     ... 
     return xXx; 
    } catch (Exception ex) { 
     hasError = true; 
     em.getTransaction().rollback(); 
    } finally { 
     em.close(); 
     if (!hasError) { 
      em.getTransaction().commit(); 
     } 
    } 
    return null;  
} 

:이처럼 내 코드는 모습입니다. SwingUtilities.invokeLater() 메서드를 제외하고 예상대로 작동합니다.

finally은 새 스레드의 모든 코드가 실행되기 전에 도달합니다. 따라서 SwingUtilities.invokeLater() 안에 JPA 작업이 있으면 트랜잭션이 커밋되었으므로 실패합니다.

try - catch - finally의 일반적인 사용 사례는 SwingUtilities.invokeLater() 내부의 코드를 포함하여 모든 코드가 실행 된 후에 만 ​​트랜잭션이 커밋된다는 것을 확인할 수 있습니까?

Answer 1

당신의 접근 방식에 대해 다시 생각해 봐야합니다. 우선 SwingUtilities.invokeLater()은 JPA 작업 수행을위한 최상의 선택이 아닙니다. 이 유틸리티 메소드의 주요 목적은 UI 업데이트입니다. 코드와 관련하여 JPA 작업에 대해 별도의 스레드를 구현하면이 스레드는 트랜잭션 상태를 수신합니다. 트랜잭션이 완료되면 UI를 업데이트합니다.

/** 
* Transaction callback. 
*/ 
public interface TransactionListener { 
    void onTransactionFinished(boolean hasError); 
} 

/** 
* Worker Thread which takes data and performs JPA operations. 
*/ 
public class JPATask implements Runnable { 
    private final Object dataToPersist; 
    private final TransactionListener transactionListener; 

    public JPATask(Object dataToPersist, 
      TransactionListener transactionListener) { 
     this.dataToPersist = dataToPersist; 
     this.transactionListener = transactionListener; 
    } 

    private EntityManager getEntityManager() {/* code is omited */} 

    @Override 
    public void run() { 
     EntityManager em = getEntityManager(); 
     try { 
      em.getTransaction().begin(); 
      // perform JPA actions here 
      em.getTransaction().commit(); 
      transactionListener.onTransactionFinished(false); 
     } catch (Exception ex) { 
      em.getTransaction().rollback(); 
      transactionListener.onTransactionFinished(true); 
     } 
    } 
} 

/** 
* Finally you method. Now it looks like this. 
*/ 
public Object methodA() { 
    JPATask jpaTask = new JPATask(<data to persist>, new TransactionListener() { 
     @Override 
     public void onTransactionFinished(boolean hasError) { 
      // Update UI. It's time to use SwingUtilities.invokeLater() 
     } 
    }).start();  
}