Bounded kanal

Bounded kanalda backpressure ve WaitToWriteAsync öğrenirsin.

Bounded kanal ve backpressure

Bounded kanalda kapasite dolunca WriteAsync yer açılana kadar bekler; buna backpressure denir. Bu, üreticiyi tüketici hızına yavaşlatır ve bellek şişmesini önler.

WaitToWriteAsync() ise yazılabilir olana kadar bekler ve ValueTask<bool> döndürür. TryWrite ise beklemeden anında false döner; backpressure'ı senkron algılamanın yoludur.

BoundedChannelFullMode

BoundedChannelFullMode ile dolma davranışını seçersin: Wait (bekle, varsayılan), DropOldest (en eskiyi at), DropNewest (en yeniyi at), DropWrite (yazmayı at).

Örn. new BoundedChannelOptions(3) { FullMode = BoundedChannelFullMode.DropOldest } ile kanal dolduğunda en eski öğeyi atar. Log akışında eski kayıplar tolere edilebiliyorsa uygundur.

Uygulama Bounded kanalda TryWrite dene

Kapasitesi 2 olan bounded bir string kanalı yarat. channel.Writer.TryWrite ile üç öğe ("a", "b", "c") yaz ve her çağrının bool sonucunu Console.WriteLine ile yazdır. Üçüncü çağrı False döner çünkü kanal doludur.

Örnek çözümü göster

var channel = Channel.CreateBounded<string>(2); Sonra Console.WriteLine(channel.Writer.TryWrite("a")); Console.WriteLine(channel.Writer.TryWrite("b")); Console.WriteLine(channel.Writer.TryWrite("c"));
Örnek çözüm:
using System;
using System.Threading.Channels;

class Program
{
    static void Main()
    {
        var channel = Channel.CreateBounded<string>(2);
        Console.WriteLine(channel.Writer.TryWrite("a"));
        Console.WriteLine(channel.Writer.TryWrite("b"));
        Console.WriteLine(channel.Writer.TryWrite("c"));
    }
}

Kendini test et

WaitToWriteAsync ne döndürür?
- void
- string
- int
- ValueTask<bool>
Cevabı göster

ValueTask<bool> — Doğru. WaitToWriteAsync ValueTask<bool> döndürür.
FullMode davranışlarını eşleştir

Wait

Doluysa bekler
DropOldest

En eskiyi atar
DropWrite

Yazmayı sessizce atar

WaitToWriteAsync koşulunu tamamla

if (await channel.Writer.____) { channel.Writer.TryWrite("x"); }

Cevabı göster

if (await channel.Writer.WaitToWriteAsync()) { channel.Writer.TryWrite("x"); }

Sıradaki ders: Kanal tamamlama

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler