세션이있는 비동기 서비스

Question

저장 함수를 호출 할 메서드가 있습니다. async'ly 그것의 일을하고 싶습니다. 이것은 내가 가진 것이지만, getDao.deleteAll()을 호출하면 저장된 함수가 실행되지 않기 때문에 .doWork()가 시작되지 않은 것처럼 보입니다.

@Transactional 
    public void delete() 
    { 

     final Session session = (Session) entityManager.getDelegate(); 
     ExecutorService executorService = Executors.newSingleThreadExecutor(); 
     executorService.execute(new Runnable() 
     { 
      @Override 
      public void run() 
      { 
       LOGGER.warn("starting"); 
       session.doWork(new Work() 
       { 
        @Override 
        public void execute(Connection connection) throws SQLException 
        { 
         try 
         { 

          CallableStatement purgeArchived = connection.prepareCall("{call deleteAll()}"); 
          purgeArchived.execute(); 
         } 
         catch (SQLException exception) 
         { 
          LOGGER.warn("Failed to purge archive points. Reason: " + exception); 
         } 
        } 
       }); 
       LOGGER.warn("stopping"); 
      } 
     }); 
     executorService.shutdown(); 
    } 

왜 이런 일이 나는 로거가 "starting"를 기록했다 볼 수 있지만, 그것은 "stopping"에 없었어?

Answer 1

Transactions는 일반적으로 스레드 바운드이므로 별도의 스레드가있을 때는 @Transaction이주의해야합니다.

공장 출하시 run() 내부에 entityManager을 새로 가져와야합니다.

@Async는 더 깨끗합니다. 하나의 작업 단위와 별도의 트랜잭션으로 그 치료 - 당신은 몇 가지 작업 비동기를 만들고 싶어

는 다시 엄지 손가락의 일반적으로 @Async

@Async and @Transactional: not working

와 트랜잭션 특성을 알고 있어야.