producer-consumer

3熱

2答えて

は、私は、新しいデータが利用可能であるときに呼び出されるコールバックメソッドを持っている public interface IDataSource { IAsyncResult BeginRead( byte[] buffer, int offset, int size, TimeSpan timeout, AsyncCallb

7熱

6答えて

C＃プロデューサ/コンシューマパターン

次のように単純な1プロデューサ/ 2コンシューマコードがありますが、出力にはC2だけが消費されていることが示されています。私のコードにバグはありますか？ class Program { static void Main(string[] args) { Object lockObj = new object(); Queue<string> queue

8熱

3答えて

汎用.Netプロデューサ/コンシューマ

私は、一般的なプロデューサ/コンシューマのペア+ Cのキューを処理するという考えを楽しみにしています。アイデアは、適切なIProducerインターフェイスとIConsumerインターフェイス（実装されている既定の実装）を実装するオブジェクトを作成するだけです。これは主にデリゲートで構成され、QueueProcessorクラスインスタンスに渡し、消費者の数を指定して移動します。しかし、私は自分自身

4熱

1答えて

ブロッキングキューがワーカーによって空になるのを待つ方法

私はブロッキングキューを持つ単一のプロデューサ - 単一消費者モデルを使用しています。プロデューサーが制作を終了したら、キューが空になるのを待って戻ってくるようにしたいと思います。私はBlockingQueueを実装しました。hereはMarc Gravellによって提案されました。私のモデルでは、プロデューサ（レンダラ）は、ファイルがレンダリングされている（作業者がアイテムをキューに入れてい

0熱

1答えて

単純なプロデューサ - コンシューマの問題ですが、プロデューサは古いバッファを更新します

私は2つのバッファを持っているとしましょう。プロデューサはバッファ＃1を満たし、次いでバッファ＃2をで満たす。消費者は一度に1つのバッファを消費し、それは非常に遅いです（）。それはバッファ＃1を消費している間、プロデューサは別のバッファを埋める準備ができていますが、それらはすべていっぱいであり、コンシューマは＃1でまだ完了していません。だから、プロデューサーは待っています。代わりに、私は

16熱

2答えて

Python - パイプからの単純な読み込みの行

パイプから行を読み込んで処理しようとしていますが、私は愚かなことをしています。プロデューサーは、このように、無期限のラインを生産保つために起こっている： producer.py import time while True: print 'Data' time.sleep(1) は、消費者だけで定期的にラインをチェックする必要があります。 consumer.py imp

0熱

1答えて

NSMutableDataからNSInputStreamを読み取ってNSStreamEventEndEncounteredを通知する方法

Cocoaでは、2つのNSThreads、1つのプロデューサ、および1つのコンシューマをセットアップしました。プロデューサはNSMutableDataにデータを追加し、受信者はそのデータからNSInputStreamを開き、チャンクを読み込みます。プロデューサスレッドは、コンシューマプロセスよりも速く書き込みます。これは問題ありません。しかし、生産者は限られた量の仕事しか生産せず、出て行く。消

1熱

2答えて

ルビーのOpenIDに準拠

libに私は、私はOpenIDコンシューマことができルビーのOpenID準拠のライブラリを使用しています、私はサンプルを持って、私が起動するようにサービスをしようとすると、それがどの /var/lib/gems/1.8/gems/actionpack-2.3.2/lib/action_controller/session/cookie_store.rb:163:in `ensure_session

6熱

6答えて

このPythonプロデューサ - コンシューマロックレスアプローチはスレッドセーフですか？

私は最近、単純なプロデューサ/コンシューマパターンを使用したプログラムを作成しました。当初、スレッドの不適切な使用に関連するバグがありました.Lockは最終的に修正されました。しかし、私は、プロデューサ/コンシューマパターンをロックレスな方法で実装することが可能かどうかを考えさせました。一つの生産者スレッド：私の場合は要件は簡単でした。 1つのコンシューマスレッド。キューには1つの項目だけが