ScheduledThreadPoolExecutorで実行中のジョブを取得するにはどうすればよいですか？

Question

タスクが中断されたときに、リソースの解放を強制する必要があります。そのために、this solutionを実装しました。しかしこれで、私がshutdown()と呼ぶとき、ScheduledThreadPoolExecutor.getQueue()のすべてのタスクは正しく強制されますが、私の仕事の中にはリソースが残っています。私はその動作を非常にうまく確認しました。これを理解しました。タスクが実行中のとき、彼はScheduledThreadPoolExecutorキューに存在しません（明らかに分かります）。問題は、すべてのジョブ（キュー内または実行中）のリソースの解放を強制する必要があることです。

したがって、実行中のジョブを取得するにはどうすればよいですか。あなたは良いアイデアを持っていますか？

Answer 1

ジョブを送信するときに作成するすべての未来のリストを管理することができます。 このリストを使用してすべての先物をキャンセルします。

Answer 2

あなたは（あなたが割り込みフラグを使用して、各タスクの「中断ポリシー」を実装する必要がありますThread.interruptを使用して）タスクを実行している現在、キャンセルしようとします

executor.shutdownNow() 

を呼び出すためにしたくありません。 javadocのから

実行中のアクティブなタスクすべての停止を

試み、待機中のタスクの処理を停止し、実行を待機していたタスクのリストを返します。

実行中のタスクの処理を最善の努力で止めようとしても保証はありません。たとえば、典型的な実装ではThread.interruptを介してキャンセルされるため、割り込みに応答しないタスクは決して終了しない可能性があります。

これは待機中のタスクのリストを返します。これを完全に緩めるのではなく、常に「待機リスト」に戻すことができます。あなたはまた、逃げるコードを避けるために、それを「待っている」と待っているかもしれません。たとえば、executor.awaitTermination(...)です。

tempus-fugitには、これを処理するためのいくつかの便利なクラスがあります。電話するだけで

shutdown(executor).waitingForShutdown(millis(400)); 

hereを参照してください。

また、あなたはブログの記事で概要を説明しています。それが正しいかどうかは分かりません。 Future.cancelはタスクのスケジュールを停止するだけです。ブログで例を更新して割り込みを許可する場合は、shutdownNowと同等の（つまり、cancel(true)）、それはinterruptを呼び出します。問題を解決するには、中断ポリシーの実装内で適切に対処する必要があります。結局のところ、shutdownNowを使用してとのクリーンアップを正しくキャンセルすることができると思います。