on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

fix BackgroundWorker single thread

Browse Source
This commit is contained in:
ngfrolov 2023-11-29 09:02:26 +05:00
parent 409e1be983
commit 15d329999b
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
AsbCloudInfrastructure/Background/BackgroundWorker.cs
View File

@ -31,6 +31,7 @@ public class BackgroundWorker : BackgroundService
/// Работа выполняемая в данный момент /// Работа выполняемая в данный момент
/// </summary> /// </summary>
public Work? CurrentWork; public Work? CurrentWork;
private bool isRuning;
/// <summary> /// <summary>
/// последние 16 завершившиеся с ошибкой /// последние 16 завершившиеся с ошибкой
@ -54,6 +55,9 @@ public class BackgroundWorker : BackgroundService
protected override async Task ExecuteAsync(CancellationToken token) protected override async Task ExecuteAsync(CancellationToken token)
{ {
if (isRuning)
return;
isRuning = true;
Trace.TraceInformation($"{GetType().Name} started"); Trace.TraceInformation($"{GetType().Name} started");
while (!token.IsCancellationRequested && works.TryDequeue(out CurrentWork)) while (!token.IsCancellationRequested && works.TryDequeue(out CurrentWork))
{ {
@ -82,6 +86,7 @@ public class BackgroundWorker : BackgroundService
Trace.TraceError(MainLoopLastException); Trace.TraceError(MainLoopLastException);
} }
} }
isRuning = false;
} }
/// <summary> /// <summary>
@ -96,7 +101,7 @@ public class BackgroundWorker : BackgroundService
{ {
works.Enqueue(work); works.Enqueue(work);
if (ExecuteTask is null || ExecuteTask.IsCompleted) if (ExecuteTask is null || ExecuteTask.IsCompleted)
StartAsync(CancellationToken.None).Wait(); StartAsync(CancellationToken.None);
} }
/// <summary> /// <summary>

2
AsbCloudInfrastructure/Background/PeriodicBackgroundWorker.cs
View File

@ -103,7 +103,7 @@ public class PeriodicBackgroundWorker : BackgroundService
var periodic = new WorkPeriodic(work, period); var periodic = new WorkPeriodic(work, period);
works.Add(periodic); works.Add(periodic);
if (ExecuteTask is null || ExecuteTask.IsCompleted) if (ExecuteTask is null || ExecuteTask.IsCompleted)
StartAsync(CancellationToken.None).Wait(); StartAsync(CancellationToken.None);
} }
private WorkPeriodic? GetNext() private WorkPeriodic? GetNext()