問題タブ [queue]

ジョブがキューに入れられ、FIFO 順に処理されるシステムを考えてみましょう。現在、処理されるまで平均 N 秒待機しています。ジョブの処理に平均 M 秒かかる場合、処理時間を M/2 秒に短縮すると N にどのような影響がありますか?

WCF を使用して、値を計算し、クライアントに応答を返す RESTful サービスを作成しました。

大量のトラフィックが予想されるため、キューを手動で実装する必要があるのか​​、それともすべてのクライアント リクエストを処理する必要がないのかがわかりません。

実際には、データベースに保存する必要があるクライアントから測定値を受信して​​います。各クライアントは 200 ミリ秒ごとに測定値を送信するため、複数のクライアントがある場合、多くの要求が発生する可能性があります。

そして、受信したデータに対して実行される他の操作。たとえば、クライアントは「最後の 200 回の測定値の平均を教えてください」という命令を送信できるため、この値を計算するのに時間がかかり、その間に別のクライアントから同じ要求が来る可能性があります。

WCF を使用して信頼性の高いサービスを作成する方法について、誰かアドバイスをいただければ幸いです。

ありがとう！

JobQueue クラスの実装に std::queue を使用しています。（基本的に、このクラスは各ジョブをFIFO方式で処理します）。あるシナリオでは、一発でキューをクリアしたい (キューからすべてのジョブを削除する)。std::queue クラスで使用できる明確なメソッドがありません。

JobQueue クラスの clear メソッドを効率的に実装するにはどうすればよいですか?

ループをポップする簡単な解決策が1つありますが、より良い方法を探しています。

複数のスレッドが物を入れることができ、複数のスレッドが読み取ることができるキューが必要です。

Python には少なくとも 2 つのキュー クラスと がQueue.Queueありcollections.deque、前者は後者を内部的に使用しているようです。どちらもドキュメントでスレッドセーフであると主張しています。

ただし、キューのドキュメントにも次のように記載されています。

collections.deque は、ロックを必要としない高速のアトミックな append() および popleft() 操作を備えた無制限キューの代替実装です。

私はよく理解していないと思います:これは、dequeが完全にスレッドセーフではないことを意味しますか?

もしそうなら、私は 2 つのクラスの違いを完全には理解していないかもしれません。Queue がブロッキング機能を追加していることがわかります。一方、インオペレーターのサポートなど、いくつかの deque 機能が失われます。

内部dequeオブジェクトに直接アクセスすることは、

x in Queue().deque

スレッドセーフ？

また、deque が既にスレッドセーフであるのに、なぜ Queue はその操作にミューテックスを使用するのですか?

データを処理するサービスのネットワークを構築する必要があります。各サービスには、独自のタスク キューが必要です。準備として、QueueTask、CancelTask​​、StopTask、GetTaskStatus、GetTaskProgress などの操作が必要です。

タスク キューのフレームワークまたは完全に構築された実装を探しています。

現時点では、いくつかのオプションを知っています：

MSMQ - 私のニーズには合っていますが、サポートするにはコーディングが多すぎます。

Castle.Sheduling - スケジューリング ソリューション. プラグ可能なトリガーを提供します。これを実装して、ニーズを達成できます。ただし、コーディングが多すぎます。

ServiceBUS - たとえばMassTransit。ただし、長いキューをどのようにサポートし、配管コードが必要なのかはわかりません。

理想的なソリューションは、タスク キューのホスティングを提供するフレームワークです。これにより、タスクを失うことなく再起動できます。これは、たとえば SOAP エンドポイントとしてネットワークからアクセスできます。

問題は、実際に何を使用しているのか、なぜですか？何を使用することをお勧めしますか?

Why are most priority/heap queues implemented as 0 being the highest priority? I'm assuming I'm missing out some key mathematical principle. As I was implementing my own priority queue recently it seemed easier to write the insert function if priority went up with the integer value, but apparently people smarter than me think it should go the other way.

Any ideas?

単一のサーバー キューを実装しようとして行き詰まっています。Norm Matloff の Simpy チュートリアルからいくつかの疑似コードを Python に適合させました。コードはhereです。今、仕事/顧客の平均待ち時間を計算する方法を見つけるのに苦労しています.

この時点で、私の脳は結び目を作りました！ポインタ、アイデア、ヒント、または疑似コードをいただければ幸いです。

私はActiveMQをアプリケーションに埋め込まれたインプロセスメッセージキューとして使用することを調査していますが、そのようなアプリケーションを起動する方法に少し行き詰まっています。私はそれをそのように想像しています（もちろん、擬似コード）：

私はこれの簡単なバージョンを組み立てようとしましたが、プロデューサーとコンシューマーが永遠に機能するように、または終了するように言われるまで、それらを作成する方法に固執しています。これを行うための最良の方法は何ですか？私は特に糸脱毛の側面について話している。独自のスレッドなどで何が必要/スポーンしたいのか...

私はメッセージキューベースのアプリケーションにまったく慣れていないので、例を詳しく説明してください。