consumer

1熱

1答えて

Pyramidのoauthプロバイダでリクエストトークンを生成しようとしたときに不正な署名エラーが発生しました

開発中のAPIへのアクセスを制御するPyramidアプリケーションでoauth2を使用してリクエストトークンを生成しようとしています。 this exampleから私の消費者キーと秘密の作業を確認しようとしています。ピラミッドrequest_tokenエンドポイントに私は次があります：（。ConsumerKeySecret.getByConsumerKey与えkeyためkeyとsecretのインス

0熱

1答えて

異なるスレッド上のオブジェクトのインスタンスの追跡ステータス？

私は空き時間に画像ボードスクレーパーを書いて、スレッドに関することを教えています。現在、私はこの作業を容易にするためにプロデューサ/コンシューマタイプのパターンを使用しています。しかし、私は問題に遭遇しています。現在、スレッドセーフなキューの特定の種類を監視して処理する「キュープロセッサ」があります。これらのキュープロセッサは、X秒ごとに対象キューをポーリングし、キューに処理待ちのアイテムがある

0熱

1答えて

Tkを使ってPythonで他のスレッドが終了したら、ローディング画面を閉じるにはどうしたらいいですか？

私はTkinterを使用するPython GUIを持っています。私は別の場所にデータを取得するためにSSHする必要があります。私はGUIをハングしないようにこれを行う新しいスレッドを開始します。この間、ユーザーに読み込み中であることを知らせる画面が表示されます。プログラムのデータ取得が終了したら、読み込み画面を閉じます。メインループでスレッドが完了したことを認識させるにはどうすればよいですか？私は

2熱

1答えて

Android/DalvikVMはどのようにハンドラを処理しますか？

HandlersがAndroid/DalvikVMでどのように処理されているのでしょうか。 Android用のアプリケーションを作成しています。あるクラスでは、別のクラスのメッセージを受け取るHandlerメソッドがあります。ハンドラメソッドはスレッドとして動作し、同じクラスのrun（）メソッドと非同期であるか、run（）メソッドのコード行が終了するまで待つか（アトミック操作の一種）？または、他の

-1熱

1答えて

有界バッファーを持つプロデューサー/コンシューマー

コードをチェックして、正しいトラックにいるかどうかを教えてもらえますか？私は少し失われているようです。エラーが表示されたら、私にそれらを教えてください。私がやろうとしているのは、自分自身のセマフォとGCDを使って境界バッファを解決することです。事前におかげ.. sema.c void procure(Semaphore *semaphore) { pthread_mutex_lo

5熱

2答えて

Java 6で複数のプロデューサ/コンシューマパターンを実装する最良の方法

私は複数のステップをステージ1からステージ2からステージ3からステージ4に持っているので、プロデューサはコンシューマになり、各ステージで複数のcpusを使用する複数のプロデューサ/コンシューマです。場合によっては、いくつかのパケットがステップを逃してしまう、つまりステージ1からステージ4にまっすぐ進む。私はステージごとにクラスを用意して、前のステージでBlockingQueueを共有するつもりだ

0熱

1答えて

JBossでActiveMQメッセージを受信する際の問題（低メッセージ/秒カウント）

私はリモートActiveMQサーバーとメッセージドリブンBean（4種類のBean）を使用してメッセージを消費しています。理論的には、メッセージの消費は高速でなければなりません（過去には高速でした）。現在のところ、jbossは4秒ごとに非常に遅いメッセージ数（4程度）を消費します。 AMQ Webインターフェイスの接続パネルには、jbossコンシューマからの2つの接続が表示されます。私の消費者

2熱

1答えて

Javaのプロデューサ/コンシューマパターン

Javaでプロデューサ/コンシューマパターンを実装する方法を考えています。私はスレッドが3つあり、リストを含んでいるとします（約5つのタスク）。各スレッドはリストからタスクを取得し、それを同時に実行します。私の現在のアプローチは、私が達成したかったCountDownLatch int N = 3; CountDownLatch startSignal = new CountDownLatch(