問題タブ [gpars]

以下の例に示すように、機能するループがあります。並列にしようとしていますが、エラーが発生します。並列にする方法（または問題はどこですか）？

I have updated from 'org.codehaus.gpars:gpars:1.0.0' to 'org.codehaus.gpars:gpars:1.1.0'. My code works fine in 1.0.0 but in version 1.1.0 I cannot find jsr166y.ForkJoinPool anymore.

How do I get the correct ForkJoinPool?

The code I am using is:

I have to import java.util.concurrent.ForkJoinPool to get the ForkJoinPool class. But at runtime I get the following error:

コレクションをクリアして同時に更新しようとしています。子があり、コレクション内の現在のアイテムを見つけて非同期に削除すると、多くの時間を節約できます。

ステップ 1. コレクション内のすべてのアイテムを検索します。ステップ 2. アイテムが何であるかがわかったら、それらを削除するプロセスを fork します。

エラー メッセージは次のとおりです。コレクションを 2 つの開いているセッションに関連付けようとする不正な試みです。

アイテムを見つけてからフォークすると、新しいセッションが作成され、フォークする前にコレクションが構築され、新しいセッションを使用してアイテムが削除されると推測しています。

現在のスレッドでアイテムを収集する必要があります。そうしないと、状態がどうなるかわかりません。

この fork/join 計算の例があります。誰かがここでどのように機能するかを簡単に説明してもらえますか?

gpars アクターに送信されるメッセージはコピーまたは参照されますか? バイナリ データを含むバッファリングされた出力ストリームを送信すると、正しく参照されますか、それともコピーされますか? 文字列やその他の種類のデータはどのように機能しますか? アクター用の何らかのメッセージ キューはありますか?
ありがとう。

grails 2.3.x と async を使用すると、奇妙な動作が発生しました。私はこのコードでいくつかのテストを行っています:

しかし、私のログで私は得ました：

実際、タスク (および onError クロージャー) は実行されますが、onComplete は (もちろん) 実行されません!!

私は何を間違っていますか？

Thread.sleep() を除いて、実質的にドキュメントから取得したコードです: http://grails.org/doc/latest/guide/async.html

Thread.sleep() は何らかの理由で GPars と互換性がありませんか?

ThreadPoolExecutor と CompletionService を使用した Java のコードがいくつかあります。タスクは大きなバッチでプールに送信されます。結果は完了サービスに送られ、バッチ全体が完了するのを待たずに、利用可能な場合に完了したタスクを収集します。

プール内のワーカーの総数は MAX_NUMBER_OF_WORKERS です。利用可能なワーカーなしで送信されたタスクはキューに入れられます。最大 20 個のタスクをキューに入れることができ、その後、タスクは拒否されます。

このアプローチに対応するGparsは何ですか?

gpars 並列処理に関するドキュメントを読んだところcollectManyParallel()、anyParallel()、 、 などの多くの潜在的なオプションが見つかりましたが、どれをテストすればよいかわかりfork/joinません。ドキュメントで比較として「完了」または「完了サービス」についての言及を見つけたいと思っていましたが、何も見つかりませんでした。gpars の経験者からどこから始めるべきかについての方向性/指針を探しています。