‫روش‌های مختلف انجام چند کار به صورت همزمان در C# .NET - قسمت دوم

var orders = await GetRecentOrdersAsync(userId);
var logs = await GetSystemLogsAsync();
var stats = await GetUserStatsAsync(userId);
return new DashboardDto(orders, logs, stats);

"A second operation started on this context before a previous operation completed. This is usually caused by different threads using the same instance of DbContext, however instance members are not guaranteed to be thread-safe."

builder.Services.AddDbContextFactory<AppDbContext>(options =>
{
    options.UseNpgsql(builder.Configuration.GetConnectionString("db"));
});

using Microsoft.EntityFrameworkCore;

public class DashboardService(IDbContextFactory<AppDbContext> contextFactory)
{
    public async Task<DashboardDto> GetDashboardAsync(int userId)
    {
        // ۱. شروع taskها (پرس‌وجوها بلافاصله شروع به اجرا می‌کنند)
        var ordersTask = GetOrdersAsync(userId);
        var logsTask = GetSystemLogsAsync();
        var statsTask = GetUserStatsAsync(userId);

        // ۲. منتظر ماندن برای تکمیل همه
        await Task.WhenAll(ordersTask, logsTask, statsTask);

        // ۳. بازگشت نتایج
        return new DashboardDto(
            await ordersTask,
            await logsTask,
            await statsTask
        );
    }

    private async Task<List<Order>> GetOrdersAsync(int userId)
    {
        await using var context = await contextFactory.CreateDbContextAsync();
        return await context.Orders
            .AsNoTracking()  // برای پرس‌وجوهای فقط‌خواندنی، tracking را خاموش کنید تا عملکرد بهتر شود
            .Where(o => o.UserId == userId)
            .OrderByDescending(o => o.CreatedAt)
            .ThenByDescending(o => o.Amount)
            .Take(50)
            .ToListAsync();
    }

    private async Task<List<SystemLog>> GetSystemLogsAsync()
    {
        await using var context = await contextFactory.CreateDbContextAsync();
        return await context.SystemLogs
            .AsNoTracking()
            .OrderByDescending(l => l.Timestamp)
            .Take(50)
            .ToListAsync();
    }

    private async Task<UserStats?> GetUserStatsAsync(int userId)
    {
        await using var context = await contextFactory.CreateDbContextAsync();
        return await context.Users
            .Where(u => u.Id == userId)
            .Select(u => new UserStats { OrderCount = u.Orders.Count })
            .FirstOrDefaultAsync();
    }
}

• ایزوله‌سازی: هر task یک DbContext اختصاصی دارد، یعنی اتصال پایگاه داده جداگانه. هیچ تداخلی پیش نمی‌آید.
• Dispose کردن: از await using استفاده کنید تا بعد از پرس‌وجو، اتصال به pool برگردد.
• استفاده از AsNoTracking در پرس‌وجوهای فقط‌خواندنی (read-only) ضروری است چون Change Tracker را غیرفعال می‌کند و حافظه و زمان کمتری مصرف می‌شود. همچنین، در بنچمارکهای واقعی (مثل یک اپ .NET 10 با PostgreSQL)، اجرای sequential حدود ۳۶ میلی‌ثانیه طول می‌کشد، در حالی که موازی فقط ۱۳ میلی‌ثانیه؛ یعنی بهبود قابل توجه. اگر پایگاه داده دور باشد، این تفاوت بیشتر هم می‌شود.

• تمام شدن pool اتصالات: یک درخواست حالا چند اتصال همزمان را اشغال می‌کند، که در concurrency بالا می‌تواند pool را خالی کند.
• سربار context: برای پرس‌وجوهای خیلی سریع، ایجاد task و contextهای متعدد ممکن است کندتر از sequential باشد.