TsgcWebSocketServer › プロパティ › QueueOptions
スレッド間の競合を防ぐために、内部の接続ごとのキューを通じてアウトバウンドメッセージをシリアライズします。
property QueueOptions: TsgcWSQueueServer_Options read FQueueOptions write SetQueueOptions;Text=qmNone, Binary=qmNone, Ping=qmNone, MaxQueueSize=0, OverflowPolicy=qopDropOldest
有効にすると、メッセージは内部キューに入れられ、呼び出し元のスレッドではなく接続スレッドのコンテキストで送信されます。これにより、複数のスレッドが同じ接続に同時書き込みを行う際に必要なロックが不要になります。各メッセージタイプ（Text、Binary、Ping）に独立した優先度レベルを割り当てることができます。qmNone はキューをスキップし（デフォルト）、qmLevel1 が最初に処理され、次に qmLevel2、最後に qmLevel3 の順に処理されます。例えば、Text と Binary を qmLevel2 に、Ping を qmLevel1 に設定すると、通常のトラフィックよりもピングが先に配信されることが保証されます。QueueOptions は IOHandlerOptions が iohIOCP に設定されている場合はサポートされません。
MaxQueueSize は、接続ごとの各キューが保持できるメッセージ数を制限します。ゼロ（デフォルト）は無制限を意味し、以前の動作が維持されます。制限に達すると、OverflowPolicy が新しいメッセージの扱いを決定します。qopDropOldest（デフォルト）は空きを作るためにキュー内の最も古いメッセージを破棄し、qopDropNewest は新しいメッセージを破棄し、qopDisconnect は新しいメッセージを破棄して接続を閉じます。制限に達するたびに、まず OnSendBufferFull イベントが発生するため、アプリケーションは低速なコンシューマーを検出したり、破棄を上書きしたりできます。
oServer := TsgcWebSocketServer.Create(nil);
oServer.QueueOptions.Text := qmLevel2;
oServer.QueueOptions.Binary := qmLevel2;
oServer.QueueOptions.Ping := qmLevel1;
oServer.Active := true;