Spring Abbrechen @ Async Aufgabe

Question

Ich möchte in der Lage sein, eine Methode mit der @Async Annotation von seiner Zukunft markiert zu stornieren.

Ich habe eine Spring-Methode mit der @Async Annotation markiert. Diese Methode führt eine Berechnung durch und gibt schließlich ein Ergebnis zurück. Alle Beispiele, die ich gesehen habe, empfehlen die AsyncResult Klasse, um diese Zukunft zurückzugeben.

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

Ich rufe die folgende Methode aus einer anderen Komponente auf die folgende Weise. Zum Beispiel möchte ich diesen Thread sofort abbrechen:

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

In diesem Fall wird der Thread nie abgebrochen. Dies ist der Fall, wenn man sich die Spring-Implementierung für AsyncResult hier anschaut: https://github.com/spring-projects/spring-framework/blob/master/spring-context/src/main/java/org/springframework/scheduling/annotation/AsyncResult.java#L71, diese Methode macht eigentlich keine einzige Sache. Es gibt einfach false zurück, dass der Thread nicht abgebrochen werden konnte. Das ist mein Problem. Wie kann ich den Thread löschen, der mit der Methode @Async erstellt wurde? Ich habe keinen Zugang zu dem internen Thread, der von Spring erstellt wird - also habe ich keine Mittel, mit denen ich es abbrechen kann, oder?

Answer 1

Tatsächlich verwendet Frühling @Async einen Hintergrundthread-Pool seiner eigenen. Und solange die Methode cancel() von Future oder shutdownNow() des Executor-Dienstes betroffen ist, wird der laufende Thread durch den Aufruf executor.shutdownNow() or future.cancel(true) nicht sofort gestoppt. Was diese Methoden tun, ist einfach .interrupt() auf den jeweiligen Thread (s) zu nennen. Und interrupts hat keine garantierte sofortige Wirkung. Es wird ein Flag ausgegeben, so dass der Thread im Schlaf- oder Wartezustand gestoppt wird. Wenn Ihre Aufgaben die Unterbrechung ignorieren, verhält sich executor.shutdownNow() and future.cancel(true) genauso wie executor.shutdown() and future.cancel(false).

Wenn Sie eine Möglichkeit benötigen, den langsamen oder blockierenden Vorgang zu stoppen. Wenn Sie eine lange/endlose Schleife haben, können Sie einfach eine Bedingung hinzufügen, ob Thread.currentThread().isInterrupted(), und nicht fortfahren, wenn es wahr ist (die Operation beenden).