問題タブ [futuretask]

ThreadPoolExecutorでいくつかのタスクを実行しています。私はそれを次のように初期化します：

送信されたタスクの進行状況を追跡VideoExportThreadするメソッドを含むrunnable（）の独自の実装を作成しました。getProgress()私はこれのインスタンスを次のように提出します：

現在/保留中のスレッドについてexecutor/blockingQueueにクエリを実行する方法を探しています。executorメソッドを使用jobQueue.toArray()してオーバーライドしようとしましbeforeExecute(Thread t, Runnable r)たが、どちらの場合も、返されるランナブルはFutureTask型であり、多くのデータが含まれていません。VideoExportThread実行中のインスタンスを識別し、その進行状況を照会するために、それを使用して元のインスタンスを取得する方法はありますか？

ありがとう

ScheduledThreadPoolExecutor の仕組みを理解するのに少し問題があります (SCA を使用しているので、コード内の注釈は気にしないでください)。これは、Scheduler クラスのコードの一部です。

これは Task クラスのコードの一部です。

ここからが大当たり！どこを見ても、ScheduledFutures でキャンセルを使用し、スケジューラでシャットダウン メソッドを使用していましたが、スケジューラを停止したくありませんでした。もう少し詳しく説明しましょう。このアプリケーションでは、定期的なタスクをいつでも個別にスケジュール、停止、および再スケジュールする必要があるため、スケジューラ サービス全体をシャットダウンせずに実行を開始した単一のタスクを中断する方法が必要です。私がやろうとしていることを理解していただければ幸いです。何かアドバイスはありますか？ありがとう ：）

特定の Runnable がエグゼキューター内で実行を終了したときに、待機して通知を受ける方法を探していました。

メソッドを持つFutureTaskを見つけましたgetが、これは値を返します。私のプログラムは戻り値を期待していません。値を返す必要のない FutureTask に似たデータ構造はありますか? FutureRunnableのようなものですか？

ありがとう！

executor をシャットダウンするとき、どこで RejectedExecutionExceptions をキャッチする必要がありますか? 私は試した：

と ：

も機能しません。まだ取得中:

私は Weblogic 10.3、Spring 2.0、Oracle 11g を使用しています。「threadpoolexecutor」将来のタスク (async resp) を使用しようとすると、スレッド プール エグゼキューターによって実行される Bean が「prototype」であるため、非同期応答の待機中に次の例外が発生します。

注:Spring の ClassPathXmlApplicationContext を使用して Bean を取得している場合、例外が発生しません。これは、すべての Bean を再度ロードするため、Bean を取得するための推奨される方法ではありません。

springContextAware 、ApplicationObjectSupport; を試しました。それらも私にとってはうまくいきませんでした。

私が持っているBeanの定義は

私も試してみましlazy-init=trueたがthreadpoolexecutor、運が悪いです。