consumer

    3

    3答えて

    私は単純なマルチスレッドコンシューマ/プロデューサをやろうとしています。ここでは、複数のリーダライタスレッドがファイルからバッファに読み込み、次にバッファからファイルに読み込みます。スレッドセーフである必要があります。しかし、それは私が期待どおりに実行されていません。途中で停止しますが、毎回別の回線で停止しますか? 私が間違っていることを理解してもらえますか? #include <pthread.

    1

    1答えて

    私はoauthを使用してGoogleサービスを利用してAndroidアプリを開発しています。消費者キー/秘密が妥協されているかどうかを検出する方法があるかどうかを知りたいので、必要に応じて行動を取ることができますか?

    7

    2答えて

    私は1つのプロデューサスレッドと複数のコンシューマスレッドで次のコードを持っています。複数のコンシューマがスレッドセーフであるかどうかを知っていますか?たとえば、スレッド1が消費されている間に、そのスレッド2が同時に消費し、スレッド1で使用されているアイテムの値を変更する可能性がありますか?事前に namespace BlockingColl { public partial class Fo

    3

    1答えて

    誰でもCamel RouteでRedisIdempotentRepositoryを正常に稼働させることができましたか? 私のCamel Routeは、Java 8+、Apache Camel(2.17.1)、およびSpring Boot(1.3.3.RELEASE)を使用して構築されています。キャメルルート負荷やメッセージを処理しますが、重複を除外していない: from("activemq:gen

    0

    1答えて

    複数のコンシューマ/プロデューサの問題で少し固執しています。私の講義ノートには現れていますが、なぜ単一の消費者/生産者のアプローチがうまくいかないのか理解できません。 1つの消費者と1人のプロデューサーのための典型的なアプローチは次のようになります。私は、1つの以上の生産および/または1人の以上の消費者を持っている場合 Producer : while(true) empty

    0

    1答えて

    OSコースのCPUスケジューリングシミュレータープロジェクトを行っています。プログラムは、2つのスレッド、つまりプロデューサスレッドとコンシューマスレッドで構成されていなけれプロデューサスレッドには、システム内でプロセスを生成するジェネレータと、いくつかのプロセスを選択し、それらをReadyQueue型のバッファ(コンシューマとプロデューサによって共有オブジェクト)というオブジェクトに配置する長期

    1

    1答えて

    プロデューサタスクとコンシューマタスクを使用してファイルを操作するかなり基本的なアプリケーションがあります。ここの例に基づいていますhttp://msdn.microsoft.com/en-us/library/dd267312.aspx プログラムの基本は、Producerタスクがハードドライブ上のファイルを列挙し、ハッシュ値を計算し、その他いくつかのことを実行することです。プロデューサがファイ

    6

    1答えて

    私はhttp://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.htmlとよく似た問題があります。 Camelのロックされたスレッドを別のエンドポイントでどうやって殺すのですか? doneUoWを設定した後、エンドポイントを削除してConsumerTemplateを停止しようとしま

    0

    1答えて

    ActiveMQでは、コンシューマにメッセージを送信していましたが、コンシューマはそのメッセージを別のプロセスに転送します。私は確認が他のプロセスからブローカーに送ることができる方法があるかどうかを知りたがっていましたか? 他のプロセスとのソケット接続を使用してメッセージオブジェクトを送信し、それに対してacknowledge()メソッドを呼び出すのは疲れましたが、動作しません。 他のクラスオブジ

    0

    1答えて

    yahooのようないくつかの処理エンジンによって処理されたメッセージを承認したいと思います! S4。アダプタを使用してメッセージをエンジンに送信することしかできません。 現在、処理エンジンが私にメッセージのJMScorrelationIDを返して、メッセージが処理されたことを伝えるまで、各メッセージをアダプタに格納しています。しかし、これは各メッセージを格納するためにアダプタ上に多くのスペースを占