producer-consumer

    0

    1答えて

    現在、クライアント間でさまざまなメッセージを送受信するJMSソリューションとしてApache ActiveMQを使用しています。特定のクライアント(コンシューマーまたはプロデューサ)の稼働時間を確認したいのですが、これまでにこれを行う方法は見つかりませんでした。私はアドバイザリメッセージとStatisticsPluginをチェックし、これを行う方法についての情報はありませんが、役に立たないことは何

    0

    1答えて

    私の現在のコードはプロデューサのコンシューマの質問に答えていますが、別の方法で実装したいと思います。私はグローバル変数を使用してバッファスタックのカウントを追跡したくありません。私の思考プロセスは何ですか? typedef int semaphore; semaphore mutex, full, empty; int count = 0; union semun {

    0

    1答えて

    プロデューサ独自のSynchronizedBlockingQueueを持つ異なるスレッド。 各プロデューサはメッセージをそれ自身のキューに入れます。キューのいずれかのいずれかからのメッセージを取得し、プロセスを開始します 消費者 別のスレッド。 プロデューサーとコンシューマーのコミュニケーションには、ブローカーが必要です。ボトルネックになる可能性があります。消費者がプロデューサーと開始プロセスから

    1

    1答えて

    デフォルトのコンストラクタを使用してTPL BufferBlockを構築する場合、DataFlowBlockOptionsは無制限ですか?つまり、BufferBlockのBoundedCapacityは何ですか? As stated in this SO answerの場合、建設後にBufferBlockの値を照会も変更もできません。

    1

    1答えて

    私は、キューに格納された要素のコンテナとしてstd :: vectorを使用し、スレッド/同期にブーストを使用して、次のブロッキングキューの実装を考え出しました。私も同様の投稿hereを参照しました。 template<typename T> class BlockingQueue { public: explicit BlockingQueue(const std::vector

    1

    1答えて

    JSONをたくさんダウンロードするスクリプトがあります。 JSONがダウンロードされた後、JSONを処理していて、他の機能にそれらを送信しています。現在、私はすべてのJSONがダウンロードされ、それぞれのJSONが処理されるまで待っています。これを並行して行う方法はありますか?同様に、各JSONがダウンロードされるとすぐに移動して、いくつかのタスクを実行します。 JSONが完全にダウンロードされた

    2

    1答えて

    私は次の問題のための最善の方法を尋ねました: 私はプロデューサとコンシューマという2つの異なるプロセスを持っています。 プロデューサはアイテムを生成します。各アイテムは符号なしのintです。消費者はそれらを消費するが、通常の消費者生産者の問題とは異なり、消費者は商品生産の正確な時間を知る必要がある。 消費者はプロデューサを信頼することができないので、プロデューサはアイテムと一緒に時間を提供すべきで

    1

    2答えて

    私は、1つのスレッドがメッセージをVectorに入れ、もう1つがメッセージをVectorから取り除く、Producer/Consumerの問題の解決策を作成しようとしています。 import java.util.Vector; public class Producer implements Runnable { static final int MAXQUEUE = 5;

    3

    3答えて

    私はJavaの同期とスレッド間の通信を理解するためにPCの問題に取り組んできました。一番下にあるコードを使用して、出力が Producer produced-0 Producer produced-1 Producer produced-2 Consumer consumed-0 Consumer consumed-1 Consumer consumed-2 Producer prod

    0

    1答えて

    ユーザとカーネル空間の間に2つの共有キュー(コマンドキューと応答キュー)を構築しようとしています。カーネルがユーザ空間にメッセージを送ることができるように、ユーザ空間は処理を終えた後にカーネルに応答を送ることができます。 私が行ったことは、カーネルメモリページ(キュー用)とmmapをユーザースペースに割り当てて、ユーザーとカーネル側の両方がそれらのページにアクセスできるようになりました(ここで私は