Spring AOPのタイムアウト実行Aspect Aspect

Question

Spring AOP Aspectにタイムアウト実行を提供する方法は？

私はメソッドの実行を停止したいない場合MyAspectのロガー方法は、30秒以上の時間の実行を取るべきではありません。どのように私はこれを行うことができますか？

MyAspectコード：

@Aspect 
@Component 
public class MyAspect { 

    @Autowired 
    private myService myService; 

    @AfterReturning(pointcut = "execution(* xxxxx*(..))", returning = "paramOut") 
    public void logger(final JoinPoint jp, Object paramOut){ 
     Event event = (Event) paramOut; 
     myService.save(event); 
    } 
} 

myServiceというインタフェース：

public interface myService { 
    void save(Event event); 
} 

myServiceImpl：

@Service 
@Transactional 
public class myServiceImpl implements myService { 

    @PersistenceContext 
    private EntityManager entityManager; 

    @Override 
    public void save(Event event) { 
     entityManager.persist(event); 
    } 
} 

Answer 1

使用java.util.concurrent.Futureを入力してタイムアウトを確認します。次の例を参照してください！

@AfterReturning(pointcut = "execution(* xxxxx*(..))", returning = "paramOut") 
public void logger(final JoinPoint jp, Object paramOut){ 
    Event event = (Event) paramOut; 

    ExecutorService executor = Executors.newSingleThreadExecutor(); 

    Future<Void> future = executor.submit(new Callable<Void>() { 
     public Void call() throws Exception { 
      myService.save(event); 
      return null; 
     } 
    }); 

    try 
    { 
     future.get(30, TimeUnit.SECONDS); 
    } 
    catch(InterruptedException | ExecutionException | TimeoutException e){ 
     //do something or log it 
    } finally { 
     future.cancel(true); 
    } 

}