, обеспечивающий выполнение тайм-аута для параметра AOP Spring AOP

Question

Как я могу обеспечить выполнение тайм-аута для параметра AOP Spring AOP?

регистратор метод 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); 
    } 

}