producer-consumer

4熱

2答えて

プロデューサ/コンシューマの問題では、LinkedBlockingQueueを共有バッファとして使用したいと考えています。プロデューサスレッドは、put()メソッドを使用してキューに要素を配置し、コンシューマスレッドはtake()メソッドを使用してキュー上の要素を消費します。私の質問は、キューが空でコンシューマスレッドがtake()メソッドを呼び出す場合、プロデューサがキューに要素を置くまでス

3熱

1答えて

ローカルKafkaアプリケーションでエラーが発生しました：NoSuchMethodError：createEphemeral

sparkアプリケーションをローカルモードで実行しようとしています。すべてを設定するために、私はこのチュートリアルに従いました：ローカルのkafka/zookeeper環境を構築するための各ステップを示すhttp://blog.d2-si.fr/2015/11/05/apache-kafka-3/（フランス語）。また、私は次のような構成でIntelliJを使用します。 "127.0.0.1:2

0熱

2答えて

単純なプロデューサ - コンシューマの例C＃辞書

私は並列プログラミングの第一歩を踏み出します。私は最も単純なコードを書いたが、結果は混乱した。このコードは、プロデューサ - コンシューマパターンで上位10個の最近のアイテムを取得します。 1人の消費者と1人のプロデューサー。 2人の消費者がより良い仕事をしているが、間違っている。 public static void ProducerConsumer(string path) {

1熱

1答えて

プロデューサーとコンシューマー、Cのsempahoreで作業

私はプロデューサー/コンシューマーアプリケーションを作ろうとしています。問題は、私のプロデューサがバッファ全体を埋めることです。次に、消費者がバッファ全体を取り除いています...プロデューサがセマフォにpostを作ると、すぐにバッファからアイテムを削除するはずですか？マイコード： void* producerFunc(void* arg) { while(n_insertions <

0熱

2答えて

コンシューマ/プロデューサAWS SQSシンクロンコンシューマを使用するakaスカラ

私のアプリケーションにはプロデューサとコンシューマがあります。私のプロデューサーは不規則にメッセージを出します。いつか私のキューは空になるでしょうが、いつか私はいくつかのメッセージを持っています。私は消費者に待ち行列を聞かせてもらいたいと思います。メッセージが入っているときは、取り出してこのメッセージを処理してください。このプロセスには数時間かかることがあり、現在のメッセージの処理が完了して

0熱

1答えて

kafkaプロデューサーを使用して同じトピックにメッセージを送信するにはどうすればいいですか？

メッセージを生成して消費するセットアップ済みのkafkaクライアントがあり、プロデューサからペイロードにペイロードを送信するときに期待通りに動作しています。プロデューサに問題があります。最初のメッセージはトピックに送信できました。カフカの話題から消費する、今私は2番目のメッセージを送信しようとしていますが、消費者はカフカのトピックから2番目のメッセージを読んでいません。 producer.jsは

1熱

1答えて

サーバプロセスがクライアントの入力/メッセージを待つ最良の方法は何ですか

この質問があいまいで終わっているかあまりにも漠然と思われる場合は謝罪します。私は最高のC/Cppプログラマではありません問題）。クライアントとサーバーの2つのプロセスが実行されているとします（プロデューサとコンシューマとして表示される可能性がありますが、ここではクライアントとサーバーが良いかもしれないと思います）。サーバーは、クライアントのオフライン処理として作成されたような、クライアントの「子

1熱

1答えて

kombuで複数の仮想ホストからキューを使用する

私は以下のような状況があります。私は仮想ホストのリストを持っています。各仮想ホストにはキュー（すべての仮想ホストで同じ名前）があります。キューを同時に消費する方法はありますか？（私は各仮想ホストに対して別個のプロセスを作成したくありません）すべてのキューから消費する単一のコンシューマが必要です。私はkombuとrabbitmqを使用しています。 https://www.rabbitmq.com

2熱

1答えて

1人のプロデューサーと複数のコンシューマー

プロデューサーがバッファー（state.value）に値を生成し、複数のコンシューマーがバッファーを読み取り、配列内で値を更新している状況で作業しようとしています。以下はコードです。 #include <pthread.h> #include <stdio.h> #include <stdlib.h> pthread_mutex_t mutex; pth

0熱

1答えて

なぜこのスレッドは決して宣言されたり開始されたりしないのですか？

私は、プロデューサ - コンシューマモデルでイメージダウンローダを実装しています。 1つのスレッドは（URL、ファイル名）のペアを生成してキューに入れます。 MAX_THREADSスレッドがペアを選択してダウンロードを開始します。ここに私のスレッドです： class Extractor(Thread): def __init__(self, group=None, target=None