Spring Cancel @Async Task

Question

Chcę móc anulować metodę oznaczoną adnotacją @Async według jej przyszłości.

Mam metodę Spring oznaczoną adnotacją @Async. Ta metoda wykonuje pewne obliczenia i ostatecznie zwraca wynik. Wszystkie przykłady, które widziałem, polecają użycie klasy AsyncResult, aby zwrócić tę Przyszłość.

@Async 
public Future<String> run() { 
    // ... Computation. Minutes pass ... 
    return new AsyncResult<String>("Result"); 
} 

Następującą metodę nazywam z innego komponentu w następujący sposób. Na przykład, chcę natychmiast anulować ten wątek:

Future<String> future = component.run(); 
future.cancel(true); 

W takim przypadku wątek nigdy nie zostanie anulowany. Wynika to z tego, że patrząc na wiosenną implementację dla AsyncResult tutaj: https://github.com/spring-projects/spring-framework/blob/master/spring-context/src/main/java/org/springframework/scheduling/annotation/AsyncResult.java#L71, ta metoda w rzeczywistości nie czyni nic. Zwraca false, że wątku nie można anulować. To jest mój problem. Jak mogę anulować wątek tworzony przez metodę @Async? Nie mam dostępu do wewnętrznej nitki tworzonej przez Spring - więc nie mam środków, dzięki którym mogę ją anulować, prawda?

Answer 1

Faktycznie, wiosna @Async wykorzystuje pulę wątków tła z własnej. A jeśli chodzi o metodę cancel() Future lub shutdownNow() usługi executora, wywołanie executor.shutdownNow() or future.cancel(true) nie zatrzymuje natychmiast bieżącego wątku. Metody te to po prostu wywołanie .interrupt() w odpowiednim wątku (wątkach). I interrupts ma nie gwarantuje natychmiastowego efektu. Wydaje flagę, więc w stanie uśpienia lub oczekiwania wątek zostanie zatrzymany.

Należy zauważyć, jeśli twoje zadania ignorują przerwanie, executor.shutdownNow() and future.cancel(true) zachowuje się dokładnie tak samo, jak executor.shutdown() and future.cancel(false).

Jeśli potrzebujesz sposobu na zatrzymanie powolnej lub blokującej operacji. Jeśli masz długą/nieskończoną pętlę, możesz po prostu dodać warunek, czy Thread.currentThread().isInterrupted() i nie kontynuować, jeśli jest prawdą (zakończyć operację).