ChannelReader

ChannelReader<T> ile kanaldan okumayı öğrenirsin.

ChannelReader<T>

ChannelReader<T>, kanalın tüketici yüzüdür. ReadAsync() tek öğeyi zaman uyumsuz okur; kanal boşsa ve tamamlanmadıysa bekler. TryRead(out T item) anında dener.

ReadAllAsync() ise bir IAsyncEnumerable<T> döndürür; await foreach ile kanal tamamlanana kadar tüm öğeleri akıtırsın. Bu, en yaygın tüketim desenidir.

await foreach ile tüket

await foreach (var item in channel.Reader.ReadAllAsync()) kalıbı, kanaldan tüm öğeleri sırayla tüketir. Kanal tamamlanınca (Writer.Complete()) döngü zarif biçimde sonlanır.

Bu, üretici-tüketici akışında kaybolan öğe olmamasını sağlar. Döngü gövdesinde öğeyi işler, filtreler veya bir koleksiyona eklersin. Tamamlanmamış bir kanalda döngü, yeni öğeler geldikçe devam eder.

Uygulama Yaz ve oku

channel sınırsız bir string kanalıdır. await channel.Writer.WriteAsync ile üç öğe yaz ("a", "b", "c"). Sonra for döngüsünde üç kez await channel.Reader.ReadAsync() ile okuyup her öğeyi yazdır. Main metodunu async Task yap.

Örnek çözümü göster

Üç kez await channel.Writer.WriteAsync(...) çağır. Sonra for (int i = 0; i < 3; i++) { var item = await channel.Reader.ReadAsync(); Console.WriteLine(item); }
Örnek çözüm:
using System;
using System.Threading.Channels;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        var channel = Channel.CreateUnbounded<string>();
        await channel.Writer.WriteAsync("a");
        await channel.Writer.WriteAsync("b");
        await channel.Writer.WriteAsync("c");
        for (int i = 0; i < 3; i++)
        {
            var item = await channel.Reader.ReadAsync();
            Console.WriteLine(item);
        }
    }
}

Kendini test et

ReadAsync çağrısını tamamla

var item = await channel.Reader.____;

Cevabı göster

var item = await channel.Reader.ReadAsync();

Okuma metotlarını eşleştir

ReadAsync

Tek öğe zaman uyumsuz oku
TryRead

Anında dene, bool döndür
ReadAllAsync

Tüm akışı oku
ChannelReader ile tüm öğeleri akış olarak okumak için hangi metot kullanılır?
- ReadAll
- ReadAllAsync
- ReadEverything
- ReadStream
Cevabı göster

ReadAllAsync — Doğru. ReadAllAsync tüm akışı döndürür.

Sıradaki ders: Bounded kanal

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler