問題タブ [queueing]

AMQP関数consume（）は、コールバックを使用したブロッキング関数です。consume（）関数のタイムアウトを設定できるので、特定の時間が経過してもブロックされなくなり、コードの実行が完了しますか？

選択した音楽ファイル ディレクトリから生成されたリストから ogg サウンド ファイルを再生しています。なぜか1曲目を飛ばして2曲目から再生。何らかの理由で、最初の曲の一瞬が時々再生されるため、ループ内のリストから曲をキューに入れようとしている方法に問題があると思われますが、修正できないようです.

私は、 ThreadPoolExecutorに関する Oracle のドキュメントを読んでいました。特に、利用可能なスレッドよりも多くのリクエストがある場合のキューイングについて読んでいました。ただし、デフォルト設定が何であるかはわかりませんでした。

Executor をインスタンス化するには、次のことだけを行います。

ここで、executor は java.util.concurrent.ExecutorService からのもので、Executor は java.util.concurrent.Executors によって指定されたものです。

そこから、エグゼキュータが再び表示される唯一の行は次のとおりです。

ご覧のとおり、エグゼキューターが使用しているキューの種類やサイズに関するプロパティは設定していません。

私が知りたいのは、リンクしたドキュメントに記載されているどの戦略が使用されているかです。

私が示した実装では: 無制限のキューを使用していますか? 有界ですか？もしそうなら、デフォルトのサイズは何ですか？

RabbitMQ から読み取るメソッドを呼び出すタスクを実行しています。キューに何もない場合、メソッドは単純にブロックされます。したがって、タスクのステータスは「実行中」ですが、実際には何も実行されていません。これらのタスクを正常に終了する方法はありますか?

キューにアクセスするコードは次のとおりです。

タスクは次のように作成されます。

現在、タスク作成コードを次のように変更して、タスクを中止できるようにしました。これが良い解決策ではないことはわかっていますが、他に何をすべきかわかりません。

Oracle Advanced Queueing について混乱しています。データベース通知をアプリケーション層に非同期で送信する方法のようです。しかし、いくつかの詳細を見ると、テーブルの横に、セットアップするキューがあります。また、後でアプリケーション層にプッシュされるメッセージを発行するための明示的な呼び出しがあります。

これはテーブル行の変更で自動的に機能しますか? 特定のテーブルが変更された場合 (誰がどのように変更されたかに関係なく)、変更された行を表すバイナリ オブジェクトの形式でそれに関する通知を受け取りたいです。

(注: Oracle クエリ変更通知、CQN については知っていますが、そのパフォーマンスには満足していません。私の目標は、Oracle Advanced Queue が同様の目標をより高速に提供できるかどうかを確認することです)。

前もって感謝します。

私は最近、フェデレーション経由で接続された Google Computer Engine と AWS で RabbitMQ クラスターをセットアップする作業を行っています。これまでのところ、解決方法がわからない問題に遭遇しましたが、問題なく動作させることができました。

ある時点で、GCE クラスター内のすべての VM を削除してから再作成するとどうなるかを確認したいと思いました。クラスターを元に戻すことができましたが、以前にフェデレーションされていた AWS クラスター交換は、GCE から AWS への新しいフェデレーション リンクが作成された後も、キューに入れられたメッセージを保持し続けました。AWS クラスター上のすべての新しいメッセージはフェデレーション リンクを介して取得されていましたが、キューに入れられた古いメッセージも送信されていませんでした。

これらの古いメッセージを新しいフェデレーション リンクにも送信するにはどうすればよいですか?

Simpy 2.6 を使用して、救急部門の患者の流れを記述するプロジェクトに取り組んでいます。

吸気エリアに 3 人の医師がいるとします。私のプロセスは、ある特定の医師 (たとえば、X 医師) を診察した後、患者は (80% の確率で) 検査室に行くというものです。臨床検査の後、患者はキューに再び参加することで元の医師 X に戻ります。

しかし、どうすれば患者と医師の間のリンクを作成できますか? 現在、私のコードの患者は「無記憶」です - 彼らは実験室のテストの後にランダムな医者に会います. インテークエリアには全部で20床あります。

私を助けてください！前もって感謝します！！

私は 2 次元のマルコフ連鎖を持っており、定常状態の確率を計算してから、予想される顧客数、予想される待ち時間などの基本的なパフォーマンス測定値を計算したいと考えています。以下の遷移率図のリンクを確認できます。

http://tinypic.com/view.php?pic=2n063dd&s=8

解法を探していると、行列幾何学的およびスペクトル展開法が表示されます。行列幾何学的手法を試しましたが、私のマルコフ連鎖は反復的ではないため、うまくいきませんでした。

いくつかの論文を読みました (例: マルコフ モデルのクラスのスペクトル展開ソリューション: 行列幾何学的方法との適用と比較) が、行列の作成方法と定常状態の確率を理解できませんでした。

1. スペクトル展開法は、行列幾何学的方法のように「反復プロセス」を必要としますか? いいえの場合、私の問題にどのように適用しますか?
2. 計算する他の方法はありますか？

ご助力いただきありがとうございます！

アリ