producer-consumer

0熱

1答えて

編集：私はSharedBufferクラスにデータを送るプロデューサクラスを持っています。このデータは、制限が100に設定されたArrayListに追加されます。リストにデータを追加することは問題ありませんが、コンシューマクラスはリストからデータを取得できません。出力が全く生成されません（ヌルまたはエラーなし）。編集2：データを配列に入れる方法が追加されました。 SharedBufferクラス

2熱

2答えて

Linuxでコンパイルされた以下のCコードのセグメンテーションフォルト

1人のシェフとの複数のゲストを持つタンデオリチキンランチビュッフェレストランをシミュレートします。これは単一のプロデューサ/複数の消費者の問題に似ています。私たちは、それぞれがシェフまたはゲストのいずれかを保持する複数のスレッドを持つ1つのプログラムを実装します。の共通リソースを複数のスレッドと同期させる問題を解決できる同期ツール - セマフォも1つ適用します。このプロジェクトでは、マルチ

0熱

1答えて

ActiveMQキューで古いメッセージを取得する方法

Iamは、Session.CLIENT_ACKNOWLEDGEを使用するコンシューマを使用しているiMemでActiveMQアプリケーションを処理しています。消費者のキューから受信したメッセージをWebサービスに送信しています。私がmessage.acknowledge（）を実行しなかった場合は、Webサービスに送信されたすべてのメッセージがキューに入れられます。私の質問は、キューから再びメッ

0熱

1答えて

マルチスレッドプロデューサーおよびコンシューマー・セマフォとC

私は仕事に私のプロジェクトを取得して問題を抱えています中とは、誰かが助けることができ期待していました。次のようなガイドラインは以下のとおりです。あなたは4つのプロデューサースレッドと4つの消費者のスレッドを作成するために pthreadのパッケージを使用します。各生産者スレッドはサイズ10,000,000文字のバッファに文字「X」を挿入します。各消費者スレッドはバッファから最も最近に挿入さ文

3熱

1答えて

ActiveMQトランスポート：tcp：スレッドRUNNABLE状態 - スレッドが多すぎます

ActiveMQの実装がコード内にあります。時々、システムは動作を停止し、非常に遅くなります。私がJavaMelodyを使用してスレッドダンプをチェックしたとき - 私はあまりにも多くのスレッドがRunnable状態に長時間入っているのを見て、終了していません。 ActiveMQのバージョン - ActiveMQの-すべて-5.3.0.jar はコードの下に参照してください：ブローカー： pub

1熱

2答えて

セマフォを使用してモニタプログラムがJavaで期待どおりに動作しない

Javaで複数のプロデューサ複数消費者問題の解決策（つまりモニタ）を作成しようとしています。私はSemaphoreクラスを使用することを決め、次のように同期しました。 import java.util.concurrent.Semaphore; public class PC implements Runnable { Semaphore s; Object lock;

0熱

1答えて

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

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

1熱

1答えて

同時実行性：コードの共通ブロックが完了するまで待ちます。

私はマルチスレッドサーバを作成しています。クライアント要求を処理し、完了したらクライアントに戻す必要があります。私は、ペイロードを共通キューに渡す同時クライアント接続オブジェクトのリストを持っています。キューを通過した後、ペイロードはサーバーによって処理され、応答が生成されます。問題は、サーバーに処理が完了したことをクライアントに通知する方法がわかりません。これは、ペイロードが以前にクライア

2熱

1答えて

TPLデータフロー - 非常に速いプロデューサー、非常に高速なコンシューマーOutOfMemory例外

私はTPL Dataflowをプロダクションコードに移植する前に実験しています。プロダクションコードは古典的なプロデューサ/コンシューマシステムです。プロデューサは（金融ドメインに関連して）メッセージを生成し、コンシューマはそれらのメッセージを処理します。私が興味を持っているのは、ある時点でプロデューサーが消費者よりもはるかに速く生産するならば、安定した環境が維持されることです（システムが爆発

1熱

1答えて

複数の消費者が同じ価値を持っている

私は、何らかの種類のプロデューサー/消費者シナリオについていくつかの概念的アドバイスを得たいと考えています。私は通常、定期的にいくつかの整数値または倍精度値を作成する "プロデューサー"スレッドがあるとしましょうが、その間に任意の遅延があるかもしれません。ここでは、値が到着するとすぐに、この値を使って何かを並行して実行しなければならないいくつかの「コンシューマ」スレッドがあります。「コンシュ