From 65159529dd7c4764055ccd0a2ab92275d28ea32e Mon Sep 17 00:00:00 2001 From: Antoine Aflalo Date: Mon, 4 Oct 2021 20:12:42 -0400 Subject: [PATCH] tests(TaskScheduler): Change the way the counter works --- Job.Scheduler.Tests/JobSchedulerTests.cs | 2 +- Job.Scheduler.Tests/Mocks/MockTaskScheduler.cs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Job.Scheduler.Tests/JobSchedulerTests.cs b/Job.Scheduler.Tests/JobSchedulerTests.cs index b57db8a..b975263 100644 --- a/Job.Scheduler.Tests/JobSchedulerTests.cs +++ b/Job.Scheduler.Tests/JobSchedulerTests.cs @@ -91,7 +91,7 @@ public async Task ExecuteInOwnScheduler() await jobRunner.WaitForJob(); job.HasRun.Should().BeTrue(); jobRunner.Retries.Should().Be(0); - taskScheduler.Count.Should().Be(1); + taskScheduler.Scheduled.Should().Be(1); job.InitThread.Should().NotBe(job.RunThread); job.RunThread.Should().Be(taskScheduler.MainThread); } diff --git a/Job.Scheduler.Tests/Mocks/MockTaskScheduler.cs b/Job.Scheduler.Tests/Mocks/MockTaskScheduler.cs index 65e2718..59a0618 100644 --- a/Job.Scheduler.Tests/Mocks/MockTaskScheduler.cs +++ b/Job.Scheduler.Tests/Mocks/MockTaskScheduler.cs @@ -11,7 +11,7 @@ public class MockTaskScheduler : TaskScheduler, IDisposable private readonly BlockingCollection _tasksCollection = new(); public Thread MainThread { get; } private readonly CancellationTokenSource _cts = new(); - public int Count { get; private set; } + public int Scheduled { get; private set; } public MockTaskScheduler() { @@ -31,8 +31,8 @@ private void Execute() { foreach (var task in _tasksCollection.GetConsumingEnumerable(_cts.Token)) { + Scheduled++; TryExecuteTask(task); - Count++; } } catch (OperationCanceledException)