producer-consumer

-1熱

1答えて

BlockingCollectionを使用してプロデューサ/コンシューマパターンasyncにアイテムを追加する

this guideをBlockingCollectionに送信してプロデューサ/コンシューマパターンを実装しても、プロデューサ側で並列に実行するタスクを取得できません。 問題は私のforeachブロックが順番に実行されていることです。 this questionから、私はプロジェクトのコレクションPropertyLien<T>のTaskのコレクションを持っていることを理解しています。それはどうで

c# asynchronous task producer-consumer 2017-11-15

---

0熱

1答えて

カフカとスパークストリーミングシンプルプロデューサコンシューマ

プロデューサから送信されたデータがコンシューマに届かない理由はわかりません。 私はcloudera仮想マシンに取り組んでいます。 私は、プロデューサーがKafkaを使用し、消費者がスパークストリーミングを使用する単純なプロデューサーコンシューマーを作成しようとしています。 Scalaではプロデューサーコード：Scalaでは import java.util.Properties import o

scala apache-kafka spark-streaming producer-consumer 2017-11-19

---

0熱

1答えて

プロデューサ - コンシューマ、バウンダリバッファ挿入エラー？

私は、複数のプロデューサとコンシューマが境界のあるバッファで乱数を生成し消費することを必要とする代入を試みています。私は'20 5 1' を入力した後、次の出力を取得しています、今 import java.util.Deque; import java.util.LinkedList; import java.util.Random; import java.util.Scanner; i

java multithreading concurrency mutex producer-consumer 2017-11-22

---

1熱

1答えて

Cパイプ：不正なファイル記述子

Cで単純なプロデューサコンシューマプログラムを使用しています。 プロデューサがパイプに書き込もうとしたときにエラーが発生します。 同じロジックを持つ別のプログラムを書きましたが、なぜ私が知りませんか？私はこのエラーを取得する理由 誰もがアイデアを持って不正なファイルディスクリプタ： プロデューサーは、パイプ上のアイテムを書き込むことができませんでしたか？ おかげ #define READ 0 #

c fork producer-consumer 2017-11-25

---

1熱

2答えて

C言語でコンシューマコードとプロデューサコードを書き込むためのforkの使用？

私は1つのファイルすなわちプロデューサがDATA.TXTファイルを開き、TESTFILE.TXTファイルから取られた文字を追加し、consumer.cファイルにターンに合格するフォーク（）関数を使用してコードを記述する必要がありますDATA.txtファイルを開き、ファイルから文字を取り出して画面に表示します。私はロジックがどのように動作するのか知っていますが、無限ループに悩まされており、そこから抜

c operating-system fork producer-consumer 2017-12-01

---

0熱

1答えて

プロデューサコンシューマセマフォの値が正しくありません

プロセスとSystem V IPCを使用してCでプロデューサ - コンシューマの問題を実装しようとしています。 #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/sem.h> #include <errn

c process semaphore producer-consumer 2017-12-05

---

4熱

1答えて

エンドポイントが見つかりすることができませ：テスト、確認していないしてください、あなたのクラスパスが必要なキャメルコンポーネントジャー

が含まれている私はakka-camelを使用してメッセージを送受信しようとすると、下記のように生産者と消費者のためのサンプル例を作成しています： プロデューサー： import akka.actor.{Actor, ActorSystem, Props} import akka.camel.Producer class CamelJmsProducer extends Actor with

scala akka activemq producer-consumer akka-camel 2017-12-07

---

1熱

1答えて

そのチャンネルのデータを受信して​​いるゴルーチンからオブジェクトをチャンネルに追加するにはどうすればよいですか？

基本的には、goroutinesを使用して同時サイトマップクローラを作成しようとしています。一つのサイトマップは今のところなど を他のサイトマップへのリンクを含めることができ、複数のサイトマップへのリンクを含めることができ、これは私のデザインです： worker: - receives url from channel - processesUrl(url) processU

go concurrency producer-consumer goroutine 2017-12-15

---

-1熱

1答えて

単純なプロデューサーとコンシューマーのunique_lockでの難しさ

C++の11個のノートに基づいて非常に単純なプロデューサー/コンシューマーを作成しましたが、なぜunique_lock（）が範囲外になったときにロックを解除しないのかわかりません。 struct Message{ Message(int x):data(x){cout<<"+";} int data; }; queue<Message*> g_queue; condition_var

c++ c++11 producer-consumer unique-lock 2017-12-20

---

1熱

2答えて

Javaマルチスレッドプログラムでプロデューサコンシューマスレッドの交換可能な役割

目的：プロデューサとコンシューマスレッドが互換性を持つように2つのスレッドを作成する。 詳細：バッファを介して互いに通信します.1つの整数サイズを格納します。例えば、最初のスレッドが1を生成した場合、2番目のスレッドはそれを消費して2を生成し、次に1番目のスレッドは2を消費し、次の3つの整数を生成し、Consumerはそれらを1つずつ消費します。 その後、両方のスレッドが終了します。 また、両方の

java multithreading producer-consumer 2017-12-25

---