問題タブ [concurrent-queue]

これで、concurrent_vector または queue に一連の自己定義データ型オブジェクトを保持する必要があるソルバーができました。オブジェクトは異なるスレッドから取得されるため、並行処理する必要があります。この並行コンテナーを使用して、これらのオブジェクトを並べ替え、重複を排除し、他のスレッドがそれらを必要とするときにそれらを送り返したいと考えています。

ただし、TBB が、異なるスレッドから同時に読み書きできる concurrent_vector と concurrent_queue を提供していることは知っています。しかし、コンテナ内のオブジェクトをソートするにはどうすればよいでしょうか? 誰もがそれを行う方法を知っていますか? ありがとう。

キューにアイテムがない場合、ConcurrentQueue の TryDequeue は false を返します。

キューが空の場合、新しいアイテムがキューに追加されるまでキューが待機し、その新しいアイテムをデキューする必要があり、プロセスはそのように続行されます。

C# 4.0でmonitor.enter、wait、pulse、またはその他のより良いオプションを使用する必要がありますか?

Visual Studio 2010 の Concurrency ライブラリを使用して、スレッド間でアクションを渡したいと考えています。私は自分のクラスを持っており、SimpleActionそれへのポインタはConcurrency::concurrent_queue.

この定義と「消費」ロジックを使用すると、次のように機能します。

ただし、これを std::unique_ptr に変更すると、次のようになります。

コンパイラは次のエラー メッセージを表示します。

コンパイラは、concurrent_queue でのこの構成を好まないようです。

これは論理的に思えます (std::unique_ptr をコピーする必要はありません (代わりに移動する必要があります)。

質問:

• これは、Visual Studio 2010 の同時実行/PPL ライブラリの既知の問題/制限/機能ですか?
• この問題は Visual Studio 2012 で解決されていますか?
• それとも私は何か間違ったことをしていますか？

ありがとう、パトリック

Intel Thread Building Blocks ライブラリにはconcurrent_queueコンテナが含まれています。

残念ながら、インターネットをconcurrent_queue調べても、TBB ライブラリによって並行して使用されている例はまだ見つかっていません。

キューが最後に空になるまで、複数のスレッドがアイテムを同時にポップオフしてアイテムをプッシュする、作業中のキューの例を誰かが提供できますか?

さまざまな種類の ConcurrentQueues を処理する柔軟な方法を構築しようとしています。これは、キューを処理するほとんどのロジックが同じであるためです。

次のようになります。

outResult は正しいタイプのようですが、次のメッセージが表示されます。

問題は、私がこれを行うとうまく動作するということです:

型のハードコーディングを回避する方法はありますか? 私が作成しているメソッドに多くの柔軟性を与えてくれます。

敬具、

マティス

FileSystemWatcher新しいファイルを探している があり、ファイル名をQueue. 別のスレッドでは、キューが処理されます。私のコードは機能していますが、非同期プロセスのために情報が失われる可能性があるかどうか疑問に思っています。コメントで説明されているコードを見てください: (どこかにスレッドロックのようなものが必要だと思いますか?) (コードは簡略化されています)