Kanal tamamlama

Channel.Writer.Complete ve Completion ile kanalı kapatmayı öğrenirsin.

Kanal tamamlama

Writer.Complete(), kanala artık öğe gelmeyeceğini bildirir. Tüketici, kalan öğeleri okuduktan sonra ReadAllAsync akışı zarif biçimde sonlanır.

Reader.Completion ise bir Task'tır; kanal tamamen bittiğinde tamamlanır. Bekleyen tüketici bununla sonlanabilir. Hata ile kapatmak için Writer.TryComplete(exception) kullanılır. Bu, akışta bir üretim hatasını tüketiciye iletmeyi sağlar.

Zarif kapanış

Üretici Writer.Complete() çağırdıktan sonra, await foreach (var item in channel.Reader.ReadAllAsync()) döngüsü kalan öğeleri tüketir ve sonra biter. Bu, kanalı kapatırken veri kaybı olmadığını garanti eder.

Tüketici tarafta await channel.Reader.Completion ile kanalın tamamen bittiğini bekleyebilirsin; özellikle birden çok kanalı senkronize ederken yararlıdır.

Uygulama Complete ile akışı kapat

channel sınırsız bir string kanalıdır. await channel.Writer.WriteAsync ile üç öğe ("a", "b", "c") yaz. Sonra channel.Writer.Complete() çağır. En son await foreach (var item in channel.Reader.ReadAllAsync()) ile tüm öğeleri yazdır. Main metodunu async Task yap.

Örnek çözümü göster

Üç kez await channel.Writer.WriteAsync(...) çağır, channel.Writer.Complete(); çağır, sonra await foreach (var item in channel.Reader.ReadAllAsync()) 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");
        channel.Writer.Complete();
        await foreach (var item in channel.Reader.ReadAllAsync())
        {
            Console.WriteLine(item);
        }
    }
}

Kendini test et

Tamamlama metotlarını eşleştir

Writer.Complete()

Yazmayı bitir
Reader.Completion

Kanalın bitiş Task'ı
TryComplete(exception)

Hata ile kapat

Complete çağrısını tamamla

channel.Writer.____;

Cevabı göster

channel.Writer.Complete();

Kanala artık öğe yazılmayacağını bildirmek için hangi metot çağrılır?
- Writer.Complete()
- Writer.Close()
- Writer.Finish()
- Reader.Complete()
Cevabı göster

Writer.Complete() — Doğru. Writer.Complete() yazmayı bitirir.

Sıradaki ders: Özet - Channels

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler