Ошибка в EF Core: вторая операция началась в этом контексте до завершения предыдущей операции

Question

В моем приложении web api произошла странная ошибка: вторая операция началась в этом контексте перед завершением предыдущей операции.Ни один из членов экземпляра не гарантированно является потокобезопасным.

У меня есть процесс для расчета дня выплаты жалованья пользователя и обновления его балансов по отпуску пользователя.поэтому мне нужно перебрать пользователей и получить их баланс отпуска, а затем выполнить обновление по каждому балансу.Я не знаю, как решить эту ошибку еще.Ошибка вызвана, когда я вызываю this.SaveAll (), который содержит b

    public async Task<bool> SaveAll()
    {
        return await _context.SaveChangesAsync() > 0;
    }

, а также datacontext вводится с этим кодом:

private readonly DataContext _context;
    private readonly IAdminSettingsRepository _settingRepo;
    private readonly IAppRepository _appRepository;
    public PayrollRepository(DataContext context, IAdminSettingsRepository settingRepo, IAppRepository appRepository)
    {
        _context = context;
        _settingRepo = settingRepo;
        _appRepository = appRepository;
    }

процесс следующим образом:

public async Task<bool> ProcessPayCalendar(PayCalendar payCalendar)
        {
            List<User> users = payCalendar.Users.ToList();
            SickLeaveEntitlement sickLeaveEntitlement = await _settingRepo.GetSickLeaveEntitlement();
            AnnualLeaveEntitlement annualLeaveEntitlement = await _settingRepo.GetAnnualLeaveEntitlement();
            LongServiceLeaveEntitlement longServiceLeaveEntitlement = await _settingRepo.GetLongServiceLeaveEntitlement();
            DateTime tenYearsAgo = DateTime.Today.AddYears(-10);
            DateTime currentMonth = new DateTime(payCalendar.NextPaymentDate.Year, payCalendar.NextPaymentDate.Month, 1);
            DateTime previousMonth = currentMonth.AddMonths(-1);


            /// begin calculation for leave calendar
            users.ForEach(async user =>
            {
                decimal hoursWorked = this.CalculateWorkingHours(user);
                decimal hourlyRate = this.CalculateHourlyRate(user);
                // create pay day for user
                Payday payday = new Payday();
                payday.UserId = user.Id;
                payday.PayPeriodStart = payCalendar.PayPeriodStartDate;
                payday.PayPeriodEnd = payCalendar.PayPeriodEndDate;
                payday.PaymentDate = payCalendar.NextPaymentDate;
                payday.HoursWorked = hoursWorked;
                payday.SickLeaveAccrual = this.CalculateSickLeaveEntitlement(hoursWorked, sickLeaveEntitlement);
                payday.AnnualLeaveAccrual = this.CalculateAnnualLeaveEntitlement(hoursWorked, annualLeaveEntitlement);
                payday.LongServiceLeaveAccrual = (user.StartDateCurrentAnnualSalary > tenYearsAgo) ? 0m : this.CalculateLongServiceEntitlement(hoursWorked, longServiceLeaveEntitlement);
                payday.SickLeaveAccrualValue = payday.SickLeaveAccrual * hourlyRate;
                payday.AnnualLeaveAccrualValue = payday.AnnualLeaveAccrual * hourlyRate;
                payday.LongServiceLeaveAccrualValue = payday.LongServiceLeaveAccrual * hourlyRate;

                this.Add(payday);

                // do calculation on leave balance 
                // jika leave balance di awal bulan maka lakukan replikasi dr bulan sebelumnya.
                // closebalance menjadi opening balance bulan selanjutnya.
                LeaveBalance sickLeaveBalance = await this.GetUserLeaveBalance(user.Id, sickLeaveEntitlement, "sickLeave");
                if (sickLeaveBalance == null)
                {
                    // sickLeaveBalance =  await this.CreateLeaveBalance(user.Id,sickLeaveEntitlement,"sickLeave",payday.PaymentDate);
                    // sickLeaveBalance.CurrentBalance =+ payday.SickLeaveAccrual ;
                    // sickLeaveBalance.CurrentBalanceValue += payday.SickLeaveAccrualValue;
                    throw new Exception($"Sick Leave balance for user: {user.Username} is not found. Please report this as bug");
                }
                else
                {
                    sickLeaveBalance.CurrentBalance = +payday.SickLeaveAccrual;
                    sickLeaveBalance.CurrentBalanceValue += payday.SickLeaveAccrualValue;
                    sickLeaveBalance.LastUpdate = payday.PaymentDate;
                }

                LeaveBalance annualLeaveBalance = await this.GetUserLeaveBalance(user.Id, annualLeaveEntitlement, "annualLeave");
                if (annualLeaveBalance == null)
                {
                    throw new Exception($"Annual Leave balance for user: {user.Username} is not found. Please report this as bug");
                }
                else
                {
                    annualLeaveBalance.CurrentBalance = +payday.AnnualLeaveAccrual;
                    annualLeaveBalance.CurrentBalanceValue += payday.AnnualLeaveAccrualValue;   
                    annualLeaveBalance.LastUpdate = payday.PaymentDate;

                }
                LeaveBalance longServiceLeaveBalance = await this.GetUserLeaveBalance(user.Id, longServiceLeaveEntitlement, "longServiceLeave");
                if (longServiceLeaveBalance == null)
                {
                    throw new Exception($"Long Service Leave balance for user: {user.Username} is not found. Please report this as bug");
                }
                else
                {
                    longServiceLeaveBalance.CurrentBalance = +payday.LongServiceLeaveAccrual;
                    longServiceLeaveBalance.CurrentBalanceValue += payday.LongServiceLeaveAccrualValue;
                    longServiceLeaveBalance.LastUpdate = payday.PaymentDate;

                }
            });
            return await this.SaveAll();
        }

полная ошибка:

ошибка: Microsoft.EntityFrameworkCore.Update [10000] Исключительная ситуация в базе данных при сохранении изменений для типа контекста 'CRSApp.API.Data.DataContext'.System.InvalidOperationException: вторая операция началась в этом контексте перед завершением предыдущей операции.Любые члены экземпляра не гарантированно являются потокобезопасными.на Microsoft.EntityFrameworkCore.Internal.ConcurrencyDetector.EnterCriticalSection () в Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync (IReadOnlyList 1 entriesToSave, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) System.InvalidOperationException: A second operation started on this context before a previous operation completed. Any instance members are not guaranteed to be thread safe. at Microsoft.EntityFrameworkCore.Internal.ConcurrencyDetector.EnterCriticalSection() at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(IReadOnlyList 1 entriesToSave, CancellationToken CancellationToken) в Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync (Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) в Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync (Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) завершились ошибкой: Microsoft.AspNetCore.Diagnostics.ExceptionHandlerMiddleware [1] возникла исключительная просьба об исключенииSystem.InvalidOperationException: вторая операция началась в этом контексте перед завершением предыдущей операции.Любые члены экземпляра не гарантированно являются потокобезопасными.в Microsoft.EntityFrameworkCore.Internal.ConcurrencyDetector.EnterCriticalSection () в Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync (IReadOnlyList 1 entriesToSave, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.ChangeTracking.Internal.StateManager.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at Microsoft.EntityFrameworkCore.DbContext.SaveChangesAsync(Boolean acceptAllChangesOnSuccess, CancellationToken cancellationToken) at CRSApp.API.Data.PayrollRepository.SaveAll() in E:\CRSApp\crsapp.api\Data\PayrollRepository.cs:line 35 at CRSApp.API.Data.PayrollRepository.ProcessPayCalendar(PayCalendar payCalendar) in E:\CRSApp\crsapp.api\Data\PayrollRepository.cs:line 229 at CRSApp.API.Controllers.Admin.PayrollController.ProcessPayCalendar(PayCalendarParam param) in E:\CRSApp\crsapp.api\Controllers\Admin\PayrollController.cs:line 68 at Microsoft.AspNetCore.Mvc.Internal.ActionMethodExecutor.TaskOfIActionResultExecutor.Execute(IActionResultTypeMapper mapper, ObjectMethodExecutor executor, Object controller, Object[] arguments) at System.Threading.Tasks.ValueTask 1.get_ResultInAynInIn.CyncIn..AspNetCore.Mvc.Internal.ControllerActionInvoker.InvokeNextActionFilterAsync () в МайкрософтBoolean & isCompleted) в Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker.InvokeInnerFilterAsync () в Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.InvokeNextResourceFilter () в Microsoft.AspNetCore.Exource.Inv.Inv.AspNetCore.Mvc.Internal.ResourceInvoker.Next (State & next, Scope & scope, Object & state, Boolean & isCompleted) в Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.InvokeFilterPipelineAsync () в Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.InvokeAsync () в Microsoft.AspNetCore.Builder.RouterMiddleware.InTutAutdownAheTecText.Вызывать (контекст HttpContext) в Microsoft.AspNetCore.Cors.Infrastructure.CorsMiddleware.Invoke (контекст HttpContext) в Microsoft.AspNetCore.StaticFiles.StaticFileMiddleware.Invoke (контекст HttpContext) в контексте H. Microsoft.AspNetCore.DwareIntext.1017 *

К сведению: Я использую Dotnet Core 2.1.1, как указано ниже.

<ItemGroup>
    <PackageReference Include="Microsoft.AspNetCore.App" Version="2.1.1"/>
    <PackageReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Design" Version="2.1.0" PrivateAssets="All"/>
    <PackageReference Include="AutoMapper.Extensions.Microsoft.DependencyInjection" Version="4.0.1"/>
    <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="2.1.1"/>
    <PackageReference Include="MailKit" Version="2.0.6"/>
  </ItemGroup>

Answer 1

DbContext не является потокобезопасным

Я думаю, что ForEach является вашей проблемой.

 users.ForEach(async user =>
        {
           //....

            LeaveBalance sickLeaveBalance = await this.GetUserLeaveBalance(user.Id,});
           // .....
        });

, так как вы использовали ключевое слово async, поэтому для каждого пользователя действие будетвызовите асинхронно , чтобы выполнение вашего кода было похоже на выполнение кода ниже:

foreach(var user in users){
     //without await
     //it's an async method
    DoSomeThingAsync(user); //you called GetUserLeaveBalance in DoSomeThingAsync
}

и, как я предполагаю, GetUserLeaveBalance использует DbContext, поэтому вы используете DbContext асинхронно , и вы столкнетесь с такой ошибкой, как

Вторая операция, запущенная в этом контексте до завершения предыдущей операции ...

Вам нужноизмените свой ForEach на что-то вроде этого

foreach(var user in users){
    await DoSomeThingAsync(user); //you called GetUserLeaveBalance in DoSomeThingAsync
}