Spring Cancel @Async Task

Question

@Asyncアノテーションが付いているメソッドは、今後取り消すことができます。

私は@AsyncアノテーションでマークされたSpringメソッドを持っています。このメソッドは計算を実行し、最終的に結果を返します。私が見たすべての例では、このFutureを返すためにAsyncResultクラスを使用することをお勧めします。

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

私は以下の方法で別のコンポーネントから次のメソッドを呼び出します。例えば、このスレッドを直ちに取り消したいと思います。

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

この場合、スレッドは決してキャンセルされません。これは、AsyncResultのSpringインプリメンテーション：https://github.com/spring-projects/spring-framework/blob/master/spring-context/src/main/java/org/springframework/scheduling/annotation/AsyncResult.java#L71を見ているので、このメソッドは実際には1つのことをしないためです。単にスレッドを取り消すことができないというfalseを返します。これは私の問題です。 @Asyncメソッドで作成されているスレッドをキャンセルするにはどうすればよいですか？ Springで作成された内部スレッドへのアクセス権がありません - キャンセルする方法はありませんか？

Answer 1

実際には、@Asyncは独自のバックグラウンドスレッドプールを使用しています。また、ExecutorサービスのFutureまたはshutdownNow（）メソッドのcancel（）メソッドが関係している限り、executor.shutdownNow() or future.cancel(true)を呼び出すことによって、直ちに進行中のスレッドが停止することはありません。これらの方法は、それぞれのスレッドで.interrupt()と呼ぶだけです。そしてinterruptsはの保証なし即時効果があります。これはフラグを発行するので、スリープ状態または待機状態になるとスレッドは停止します。

タスクが中断を無視する場合、executor.shutdownNow() and future.cancel(true)はまったく同じ方法でexecutor.shutdown() and future.cancel(false)と同じ動作をします。

遅い操作またはブロックする操作を停止する方法が必要な場合は、長い/無限ループがある場合は、Thread.currentThread().isInterrupted()の条件を追加して、それが真（操作を終了）した場合は続行しないでください。