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

fix PeriodicBackgroundWorkerTest.Enqueue_Continues_AfterExceptions

Browse Source
This commit is contained in:
ngfrolov 2024-04-15 11:24:08 +05:00
parent 0b629afcf0
commit beb0d08ff5
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
AsbCloudWebApi.Tests/Background/PeriodicBackgroundWorkerTest.cs
View File

@ -67,10 +67,12 @@ public class PeriodicBackgroundWorkerTest
{ {
var expectadResult = 42; var expectadResult = 42;
var result = 0; var result = 0;
using var semaphore = new SemaphoreSlim(0, 1);
Task workAction(string id, IServiceProvider services, Action<string, double?> callback, CancellationToken token) Task workAction(string id, IServiceProvider services, Action<string, double?> callback, CancellationToken token)
{ {
result = expectadResult; result = expectadResult;
semaphore.Release();
return Task.CompletedTask; return Task.CompletedTask;
} }
var goodWork = Work.CreateByDelegate("", workAction); var goodWork = Work.CreateByDelegate("", workAction);
@ -85,12 +87,12 @@ public class PeriodicBackgroundWorkerTest
service.Add(badWork, TimeSpan.FromSeconds(2)); service.Add(badWork, TimeSpan.FromSeconds(2));
service.Add(goodWork, TimeSpan.FromSeconds(2)); service.Add(goodWork, TimeSpan.FromSeconds(2));
await Task.Delay(TimeSpan.FromMilliseconds(256)); await semaphore.WaitAsync(4_100);
//assert //assert
Assert.Equal(expectadResult, result);
Assert.Equal(1, badWork.CountErrors); Assert.Equal(1, badWork.CountErrors);
Assert.Equal(1, goodWork.CountComplete); Assert.Equal(1, goodWork.CountComplete);
Assert.Equal(1, goodWork.CountStart); Assert.Equal(1, goodWork.CountStart);
Assert.Equal(expectadResult, result);
} }
} }