concurrent-queue

2熱

1答えて

Spliteratorを使用してConcurrentLinkedQueueを半分に分割します

私はConcurrentLinkedQueueを持っています。これを2つの半分に分割し、それぞれ別々の2つのスレッドで処理します。 Spliteratorを使用しようとしましたが、パーティション化されたキューを取得する方法がわかりません。 ConcurrentLinkedQueue<int[]> q = // contains a large number of elements Spliter

0熱

1答えて

キューに処理するものがあるときにバックグラウンドスレッドをトリガーする方法

ConcurrentQueueを使用して複数のスレッドからメッセージを格納しています。キューに何かがあるときに自動的に起動されるバックグラウンドスレッドを作成するには？

0熱

1答えて

同じイベントを発生させる複数のクラスインスタンス

私のC＃コードに何が間違っているかを理解できません。 System.Collections.Concurrent名前空間でConcurrentQueueクラスを使用する方法を学習しようとしています。これを行うために、別のスレッドで同じクラスの2つのインスタンスを作成し、異なるリストボックスコントロールをコンストラクタに渡します。 EventGeneratorの各クラスインスタンスがランダムな間隔

0熱

1答えて

VB.Net：スレッド上のConcurrentQueueからアイテムを取得する

データをリッスンして文字列のConcurrentQueueにプッシュするクラスを1つのスレッドで実行しています。 Enqueueを使用してデータを追加しています。キューの長さが増えているので、データが正しくキューされていることがわかります。別のスレッドで実行される別のクラスは、FIFOベースで各データを取り出す必要があります。しかし、それは単に何もしません。 Dim data As String

-1熱

1答えて

同時キューデキュー

私は、同時キューを使用して作成アクションデリゲートによって、複数のスレッドを経由 Action action =() => { SubscriptionResponseModel subsModel; while (concurrentQueue.TryTake(out subsModel)) { MakeTransactio

2熱

2答えて

ConcurrentQueueとParallel.ForEach

私はソースを取得する必要があるURLのリストを持つConcurrentQueueを持っています。 ConcurrentQueueオブジェクトを入力パラメーターとして使用してParallel.ForEachを使用する場合、Popメソッドは何も動作しません（文字列を返す必要があります）。私はMaxDegreeOfParallelismを4に設定してParallelを使用しています。私は本当に同時スレ

1熱

1答えて

キューからの読み取りと書き込み

並行キューに〜300ビットマップのセットを保存しています。私はover-tcpビデオストリーミングプログラムのためにこれをやっています。サーバーが遅くなったら、受信したビットマップをこのキューに保存します（バッファリング）。私はこれをテストするために別のプロジェクトを作成しましたが、いくつか問題があります。書き込みスレッドが動作している間（キューに書き込む）、ピクチャボックスはキューから画像を表

1熱

2答えて

ConcurrentQueue with multithreading

私はマルチスレッドの概念に慣れていません。特定の数の文字列をキューに追加し、それらを複数のスレッドで処理する必要があります。スレッドセーフであるConcurrentQueueを使用する。これは私が試みたものです。ただし、並行キューに追加されたアイテムはすべて処理されません。最初の4項目のみが処理されます。 class Program { ConcurrentQueue<string>

2熱

1答えて

Worker Threads Blocking ConcurrentQueueの項目が多すぎる

これは奇妙なものです。ConcurrentQueue<string>の項目をそれぞれ処理するワーカースレッドのThread[]があります。キューが空になるまで、残りのプログラムは続行されます。これは、すべてのスレッドがWaitSleepJoin状態でブロックされたままで、約1500項目まで動作し、キュー内の項目を一切処理しません。私は自分のコードをステップ実行しようとしましたが、スレッドはまだ

4熱

1答えて

ConcurrentQueue .Net：マルチスレッドコンシューマ

私はConcurrentQueueという概念を中心に非常に基本的な質問がありました。キューはFIFOです。複数のスレッドがアクセスを開始すると、どのようにFIFOを保証するのですか？と仮定して、私はApple,Oranges,Lemon,PeachおよびApricotの順に追加しました。最初のTryTakeはAppleを返す必要があります。しかし、複数のスレッドが独自のTryTake要求を出し始