注文を維持する必要があるマルチスレッドジョブ

Question

キューが長く、キュー内のすべての要素が複数（TCP）サーバーに送信される である必要があるc/C++プロセスがあります。シングルスレッドは動作するオプションですが、遅いです。

マルチスレッドソリューションを実装する必要があります。私のプロセスでは、サーバの数があらかじめわかっていません。 最初のアイデアは、すべてのサーバーに1つのスレッドを作成することです。マネージャスレッドは を読み取ります。キュー内の新しい要素が宛先を検出し、宛先に一致するスレッドにディスパッチします。

重要な注意点です。ジョブは依存している可能性があります。 job_5が完了していなければjob_10を実行したくありません。注文を維持する必要があります。

まず、この問題についてご意見をお聞かせください。 2番目は、参照用にC++の実装を探しています。第3に、同様の問題を記述した書籍/情報源を探しています。

Answer 1

boost asioを見ましたか？これは "スレッドプール"という概念をサポートしているため、サーバーごとに1つのスレッド（同期）ではなく、多数の接続を非同期に処理するスレッドのプールを持つことができます。パフォーマンスはそれほど悪くはありません...

Answer 2

マルチスレッドソリューションが必要であるとの結論に至りましたか？あなたのシングルスレッドソリューションが「遅い」と言ったら、どういう意味ですか？あなたはアイテムがサーバーに送信されている間、他の処理（たぶんUIスタッフ？）が開催されていることを意味しますか？あるいは、プロセス全体が時間がかかりすぎるのか？

この質問では、各項目をすべてのサーバーに送信する必要があるのか​​、まったく送信する必要があるのか​​は不明です。ただ1つのようだが、わからない。すべてに送信する必要がある場合は、マルチスレッドソリューションの複雑さが大幅に増加します。

送信されたアイテムをキューから削除できますか、またはサーバーからの確認を待つ必要がありますか？待機する必要がある場合は、キュー管理が難しくなります。承認されるまでアイテムを削除することはできません。何らかの理由で保留中とマークする必要があります。キューから次のアイテムを選択するスレッドには、保留中のアイテムを選択しないようにします。アイテムが正常に送信されたら、キューから削除する必要があります。これは、キューへの同時書き込みアクセスを意味します。

どのようにエラーを処理しますか？アイテムを送信できない場合は、後で再試行するためにキューに残りますか、失敗したリストに移動したか、ログに記録されて破棄されただけですか？マルチスレッドシステムでは、エラーを非同期的に学習します。これは、エラー処理プロシージャへの同時書き込みアクセスを意味します。

あなたのプロセスは、そこにいくつのサーバーがあるかをあらかじめ知っていると言います。処理中にこの番号が変更できますか？

マルチスレッド化については、「低速」のシングルスレッドソリューションが、ビジネスニーズに最も適した、実装が容易で信頼性の高いソリューションであることがわかります。そうでなければ、これらの質問のいくつかがあなたに役立つことを願っています。