در گذشته، توسعه‌دهندگان دات‌نت برای پیاده‌سازی این الگوی ساختاری به ابزارهایی مانند BlockingCollection یا ترکیب ConcurrentQueue با SemaphoreSlim متکی بودند. اگرچه این ابزارها کارآمد هستند، اما در سناریوهای مبتنی بر async/await عملکرد بهینه‌ای ندارند و می‌توانند باعث انسداد نخ‌ها (Thread Blocking) و اتلاف منابع سیستم شوند.

برای رفع این مشکل، مایکروسافت در دات‌نت کور ۲.۱ فضای نام System.Threading.Channels را معرفی کرد. کلاس Channel یک ساختار داده‌ای بسیار کارآمد، Thread-safe و کاملاً سازگار با معماری Async است که برای پیاده‌سازی خطوط لوله داده (Data Pipelines) با کارایی بالا (High-Performance) طراحی شده است.

در این مقاله تخصصی، به بررسی عمیق ساختار، نحوه کارکرد، انواع کانال‌ها، استراتژی‌های مدیریت ظرفیت و نکات پیشرفته عملکردی Channel می‌پردازیم.

چرا به Channel نیاز داریم؟ (مقایسه با روش‌های قدیمی)

پیش از ورود به جزئیات فنی، باید درک کنیم چرا ابزارهای قدیمی برای کارهای مدرن کافی نیستند. بیا نگاهی به تفاوت BlockingCollection و Channel بیندازیم:

• انسداد نخ‌ها در برابر ناهمگامی مطلق: کلاس BlockingCollection برای مسدود کردن نخ (Block) طراحی شده است. وقتی مصرف‌کننده می‌خواهد داده‌ای را بخواند و صفی خالی است، نخ جاری منتظر می‌ماند. این رفتار در متدهای غیرهمگام (Async) باعث هدر رفتن نخ‌های Thread Pool می‌شود. در مقابل، Channel کاملاً بر پایه ValueTask و async/await است؛ یعنی اگر داده‌ای وجود نداشته باشد، نخ آزاد می‌شود تا کارهای دیگر را انجام دهد و به محض در دسترس قرار گرفتن داده، کار ادامه می‌یابد.
• تخصیص حافظه (Allocation): کانال‌ها به شدت برای کاهش Allocation بهینه‌سازی شده‌اند. با استفاده از ValueTask، در بیشتر مواقع که داده از قبل در صف موجود است، هیچ شیء اضافی در حافظه (Heap) ساخته نمی‌شود.

معماری و ساختار داخلی Channel

کلاس Channel یک کلاس انتزاعی (Abstract) است که به عنوان یک کارخانه (Factory) برای ایجاد دو بخش اصلی عمل می‌کند:

1. ChannelWriter: وظیفه نوشتن یا تولید داده در کانال را بر عهده دارد.

2. ChannelReader: وظیفه خواندن یا مصرف داده از کانال را بر عهده دارد.

این جداسازی وظایف (Separation of Concerns) به شما اجازه می‌دهد که اصل کمترین دسترسی (Principle of Least Privilege) را رعایت کنید. به عنوان مثال، می‌توانید بخش تولیدکننده سیستم را طوری طراحی کنید که فقط به ChannelWriter دسترسی داشته باشد و نتواند داده‌های درون صف را بخواند یا دستکاری کند.

// ساخت یک کانال ساده
Channel channel = Channel.CreateUnbounded();

ChannelWriter writer = channel.Writer;
ChannelReader reader = channel.Reader;

انواع کانال‌ها در دات‌نت

مایکروسافت دو نوع پیاده‌سازی اصلی برای کانال‌ها ارائه داده است که بسته به نیاز سیستم باید یکی از آن‌ها را انتخاب کنید:

الف) کانال‌های نامحدود (Unbounded Channels)

این کانال‌ها هیچ محدودیتی در تعداد آیتم‌های ذخیره‌شده در صف ندارند. تا زمانی که حافظه رم سیستم اجازه دهد، تولیدکننده‌ها می‌توانند در آن بنویسند.

• روش ساخت: Channel.CreateUnbounded()

• کاربرد: زمانی که سرعت مصرف‌کننده همیشه بیشتر یا مساوی تولیدکننده است و خطر پر شدن حافظه وجود ندارد.

ب) کانال‌های محدود (Bounded Channels)

این کانال‌ها ظرفیت مشخصی دارند. وقتی تعداد آیتم‌های درون صف به سقف تعیین‌شده برسد، کانال واکنش مشخصی نشان می‌دهد (مثلاً تولیدکننده را منتظر می‌گذارد یا داده‌های قدیمی را حذف می‌کند).

• روش ساخت: Channel.CreateBounded(capacity)

• کاربرد: در سیستم‌های واقعی برای جلوگیری از پدیده OutOfMemoryException و مدیریت جریان داده‌ها (Backpressure).

استراتژی‌های مدیریت رفتار در کانال‌های محدود (Full Mode Options)

وقتی ظرفیت یک BoundedChannel پر می‌شود، ما باید تعیین کنیم که سیستم چه رفتاری نشان دهد. این کار با استفاده از انوم BoundedChannelFullMode تنظیم می‌شود:

var options = new BoundedChannelOptions(capacity: 100)
{
    FullMode = BoundedChannelFullMode.DropOldest
};
Channel orderChannel = Channel.CreateBounded(options);

پیاده‌سازی عملی: الگوی Producer-Consumer با Channel

بیایید یک مثال واقعی را بررسی کنیم. فرض کن یک سیستم پردازش سفارشات فروشگاهی داریم. یک متد وظیفه دریافت سفارشات از کاربران را دارد (Producer) و یک متد در پس‌زمینه سفارشات را پردازش و در دیتابیس ثبت می‌کند (Consumer).

using System;
using System.Threading.Channels;
using System.Threading.Tasks;

public class OrderProcessor
{
    private readonly Channel _orderChannel;

    public OrderProcessor()
    {
        // ایجاد یک کانال محدود با ظرفیت 10 سفارش
        var options = new BoundedChannelOptions(10)
        {
            FullMode = BoundedChannelFullMode.Wait,
            SingleWriter = false, // چندین متد می‌توانند سفارش ثبت کنند
            SingleReader = true   // فقط یک Worker سفارشات را پردازش می‌کند
        };
        _orderChannel = Channel.CreateBounded(options);
    }

    // Producer: سفارش جدید را در کانال قرار می‌دهد
    public async ValueTask PublishOrderAsync(string orderId)
    {
        // منتظر می‌ماند تا فضا خالی شود، سپس می‌نویسد
        await _orderChannel.Writer.WriteAsync(orderId);
        Console.WriteLine($"[Producer] Order {orderId} added to queue.");
    }

    public void CompletePublishing()
    {
        // اعلام پایان کار تولیدکننده‌ها
        _orderChannel.Writer.Complete();
    }

    // Consumer: سفارشات را از کانال خوانده و پردازش می‌کند
    public async Task StartProcessingAsync()
    {
        // خواندن داده‌ها به صورت استریم ناهمگام تا زمانی که Channel.Complete صدا زده شود
        await foreach (var orderId in _orderChannel.Reader.ReadAllAsync())
        {
            Console.WriteLine($"[Consumer] Processing order: {orderId}...");
            await Task.Delay(1000); // شبیه‌سازی کار سنگین یا ذخیره در دیتابیس
            Console.WriteLine($"[Consumer] Order {orderId} processed successfully.");
        }

        Console.WriteLine("[Consumer] All orders processed. Channel is closed.");
    }
}

نحوه اجرای کد بالا در متد Main:

public static async Task Main(string[] args)
{
    var processor = new OrderProcessor();

    // شروع به کار مصرف‌کننده در پس‌زمینه
    Task consumerTask = processor.StartProcessingAsync();

    // تولید چند سفارش به صورت همزمان
    Task producers = Task.Run(async () =>
    {
        for (int i = 1; i <= 15; i++)
        {
            await processor.PublishOrderAsync($"ORD-{i}");
            await Task.Delay(200); // فاصله زمانی بین ورود سفارش‌ها
        }
        processor.CompletePublishing(); // اتمام تولید داده
    });

    // انتظار برای اتمام کار هر دو بخش
    await Task.WhenAll(producers, consumerTask);
}

تکنیک‌های بهینه‌سازی پیشرفته عملکرد (Performance Tuning)

یکی از دلایل اصلی محبوبیت Channel در کدهای Infrastructure دات‌نت (مانند SignalR و Kestrel)، گزینه‌های بهینه‌سازی آن است. با استفاده از ChannelOptions می‌توانید رفتارهای داخلی کانال را برای سناریوهای خود قفل‌گذاری و بهینه‌سازی کنید:

تنظیم SingleWriter و SingleReader

اگر مطمئن هستید که در برنامه شما فقط یک نخ یا وظیفه (Task) در کانال می‌نویسد، مقدار SingleWriter را برابر true قرار دهید. به همین ترتیب برای SingleReader.

var options = new UnboundedChannelOptions
{
    SingleWriter = true, // بهینه‌سازی داخلی برای سناریوهای Single-Producer
    SingleReader = true  // بهینه‌سازی داخلی برای سناریوهای Single-Consumer
};

نکته تخصصی: وقتی این مقادیر را true می‌کنید، کامپایلر و محیط ران‌تایم دات‌نت نیازی به قفل‌های سنگین (Lock-free synchronization overhead) برای مدیریت همزمانی ندارند و از الگوریتم‌های بسیار سریع‌تر تک‌نخی در پشت صحنه استفاده می‌کنند. این کار سرعت تراکنش‌های کانال را به شدت بالا می‌برد.

مدیریت خطا و بستن کانال

بستن درست کانال برای جلوگیری از ایجاد بن‌بست (Deadlock) در برنامه حیاتی است.

• وقتی کار تولیدکننده تمام می‌شود، باید متد Writer.Complete() صدا زده شود. این کار به مصرف‌کننده سیگنال می‌دهد که دیگر داده جدیدی در راه نیست.
• حلقه await foreach به طور خودکار پس از خالی شدن کانال و دریافت سیگنال Complete به پایان می‌رسد.
• اگر در فرآیند تولید داده خطایی رخ دهد، می‌توانید خطا را به متد کمپلیت پاس دهید: Writer.Complete(exception). در این حالت، مصرف‌کننده به محض رسیدن به خطای مذکور، اکسپشن را پرتاب (Throw) می‌کند تا سیستم از خطای رخ داده مطلع شود.

مقایسه نهایی: چه زمانی از چه ابزاری استفاده کنیم؟

کلاس Channel ابزاری استاندارد، مدرن و فوق‌العاده سریع برای پیاده‌سازی خطوط لوله داده و الگوی تولیدکننده-مصرف‌کننده در دات‌نت است. این کلاس با حذف هزینه‌های سنگین انسداد نخ‌ها و بهینه‌سازی تخصیص حافظه، به شما اجازه می‌دهد برنامه‌هایی بنویسید که به راحتی مقیاس‌پذیر (Scalable) می‌شوند.

به عنوان یک قانون کلی در مهندسی نرم‌افزار دات‌نت: برای هرگونه پردازش داده ناهمگام و صف‌بندی داخلی بین کامپوننت‌ها در دات‌نت مدرن، Channel انتخاب اول و بی‌رقیب شماست.