TsgcWebSocketServer › Özellikler › QueueOptions
İş parçacıkları arasındaki çekişmeyi önlemek için giden mesajları dahili bir bağlantı başına kuyruk aracılığıyla serileştirir.
property QueueOptions: TsgcWSQueueServer_Options read FQueueOptions write SetQueueOptions;Text=qmNone, Binary=qmNone, Ping=qmNone, MaxQueueSize=0, OverflowPolicy=qopDropOldest
Etkinleştirildiğinde, mesajlar dahili bir kuyruğa yerleştirilir ve çağıranın iş parçacığı yerine bağlantı iş parçacığının bağlamında gönderilir — bu, birden çok iş parçacığı aynı bağlantıya aynı anda yazdığında gereken kilitlemeyi ortadan kaldırır. Her mesaj türüne (Text, Binary, Ping) bağımsız bir öncelik düzeyi atanabilir: qmNone kuyruğu atlar (varsayılan), qmLevel1 önce işlenir, ardından qmLevel2 ve son olarak qmLevel3. Örneğin, Text ve Binary öğelerini qmLevel2 ve Ping öğesini qmLevel1 olarak ayarlamak, ping'lerin sıradan trafikten önce teslim edilmesini garanti eder. IOHandlerOptions iohIOCP olarak ayarlandığında QueueOptions desteklenmez.
MaxQueueSize, bağlantı başına her kuyruğun tutabileceği ileti sayısını sınırlar: sıfır (varsayılan) sınırsız anlamına gelir ve önceki davranışı korur. Sınıra ulaşıldığında yeni iletilere ne olacağına OverflowPolicy karar verir: qopDropOldest (varsayılan) yer açmak için kuyruktaki en eski iletiyi atar, qopDropNewest yeni iletiyi atar, qopDisconnect iletiyi atar ve bağlantıyı kapatır. Sınıra her ulaşıldığında önce OnSendBufferFull olayı tetiklenir; böylece uygulama yavaş tüketicileri tespit edebilir veya iletinin atılmasını geçersiz kılabilir.
oServer := TsgcWebSocketServer.Create(nil);
oServer.QueueOptions.Text := qmLevel2;
oServer.QueueOptions.Binary := qmLevel2;
oServer.QueueOptions.Ping := qmLevel1;
oServer.Active := true;