問題タブ [executor]

httpを介してパートナーサイトから10〜20枚の画像をインポートする必要があるWebアプリケーションがあります。ダウンロードしたいURLを表す文字列のリストがある場合、それらをできるだけ速くダウンロードする方法について誰かが提案を持っていますか？

それらをforループに入れることもできますが、これを並列化する簡単な方法があれば、エンドユーザーにとってはおそらく良いでしょう。エグゼキュータフレームワークは良い考えかもしれませんが、私はストレートJavaスレッドの使用を避けたいと思います。

何か案は？

私は Callable を実装するクラスにこれを持っています:

この Callable を実行する他のクラスでは、次のようになります。

しかし、エラーが発生し、SQLException が決してスローされないという IDE のメッセージが表示されました。これは、ExecutorService で実行しているためですか?

UPDATE : したがって、送信は SQLException をスローしません。Callable (スレッドとして実行) を実行して例外をキャッチするにはどうすればよいですか?

解決済み:

しばらくの間、頭がおかしくなっている問題があり、あなたの集合的な知恵に相談する必要があります.

Executors.newFixedThreadPool から呼び出された、プールが 1 の ThreadPoolExecutor があります。executor.shutdown() は別のスレッドから呼び出されるため、すべての executor.execute() を !isShutdown() で保護します。したがって、executor は RejectedExecutionException をスローしないと言えます。それにもかかわらず、これは私がランダムに見ているものです。

なぜ私がこの動作を見ているのか、誰にも良い考えがありますか?

を使用してScheduledExecutorService、固定レートでサービスを呼び出すタスクを実行しています。サービスは、タスクにデータを返す場合があります。タスクはデータをキューに格納します。他のいくつかのスレッドは、キューからアイテムをゆっくりと選択します

タスクによって入力されたキューがクリアされるまで、executorService を一時停止するにはどうすればよいですか。

ScheduledExecutorService前のタスクがまだ終了していない場合、タスクの複数のスレッドを生成するために使用することに興味があります。たとえば、0.5 秒ごとにファイルを処理する必要があります。最初のタスクがファイルの処理を開始し、最初のスレッドが終了していない場合は 0.5 秒後に 2 番目のスレッドが生成され、2 番目のファイルの処理が開始されます。これは、次のような方法で実行できます。

今私の質問：なぜ私はそれを行うことができないのexecutor.scheduleAtFixedRateですか？

私が得るのは、最初のタスクに時間がかかる場合、最初のタスクが終了するとすぐに2番目のタスクが開始されますが、エグゼキューターにスレッドのプールがあっても新しいスレッドは開始されません。executor.scheduleWithFixedDelay明確です - タスクは同じ時間間隔で実行され、タスクを完了するのにどれだけ時間がかかるかは問題ではありません。ScheduledExecutorServiceだから多分私は目的を誤解しました。

多分私は別の種類のエグゼキューターを見るべきですか？または、ここに投稿したコードを使用するだけですか? 何かご意見は？

Executors.newCachedThreadPool()スレッドをオーバースポーンするときに問題を解決できるものを使用するように勧められました。

ただし、スレッド数が特定のポイントを超えて増加すると、まだエラーが発生します。システムリソースが利用可能になるのを待っている間、スレッドがそれ自体を待機できるようにする方法はありますか?

キューなどでAsyncTask実行への複数の呼び出しを簡単に配置し、それらをシリアルに実行する方法を知っている人はいますか？

呼び出された非同期タスクが終了するまで待機させたいのですが、現在実行中のタスクのステータスをテストしても、これを実行できないようです。

これを解決する方法はありますか？ハニカムAPIには、を使用したメソッドexecuteOnExecutor()があることを確認しSERIAL_EXECUTORました。これは、私が説明したことを実装していると思います。しかし、私はハニカム用に開発していません。

ありがとう！

ThreadPoolExecutor に問題があります。何時間も問題なく動作しますが、時々 (ランダムな時間に、時には 2 分または 3 時間後に) 送信されたタスクの実行が停止し、プログラムがハングします。

キューがいっぱいで、この時点ですべてのコアスレッドがアクティブです。

これがどこから来ているのか、私にはまったくわかりません。特に、すべてのコアスレッドが常に動作しているときに 3 時間動作することがあるためです。

私に提案をしてくれる人がいれば、とてもうれしいです。

私はこのエラーに 1 週​​間悩まされてきましたが、これについて真剣に頭がおかしくなっています! 私は複数の実装と回避策とハックなどを試しましたが、別の例外にスタブリングし続けています。

Executor プラグインを使用してメソッドを非同期で実行しています。

このメソッドは、最初にいくつかのオブジェクトを削除します。

そして、後でそれらのオブジェクトを再作成する可能性があります:

しかし、それは次の例外で失敗します:

Pageとの間の関係は、属性を持つことDomainによって簡単に実装されます。いいえ、パフォーマンスの問題により、以前の投稿でこれに落胆したためです。PageDomainhasManybelongsTo

save、merge、withTransachtionおよびPersistenceContextInterceptor...の考えられるすべての組み合わせを試したと思います。

これはどのように機能するはずですか？例をください。

前もって感謝します！

私はJavaを学び始め、現在は並行性の章にいます。並行性についていくつか読んだ後、私は自分の例を試しました。

問題は、次の出力が表示されることを期待していたことです。

しかし、これを取得した後、プログラムは閉じるまで印刷を続けます。
だから、私の質問は私が間違っていることですか？プログラムが印刷を続行するのはなぜですか？