- cancellation token source

Author: eben-roux

Shuttle.Core.Threading.Tests/SharedCancellationTokenSourceFixture.cs

@@ -0,0 +1,63 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using NUnit.Framework;
+
+namespace Shuttle.Core.Threading.Tests
+{
+    [TestFixture]
+    public class SharedCancellationTokenSourceFixture
+    {
+        private static readonly Random Random = new Random(DateTime.Now.Millisecond);
+
+        [Test]
+        public void Should_be_able_to_shared_cancellation_token_source_entries()
+        {
+            using (var cancellationTokenSource = new DefaultCancellationTokenSource())
+            {
+                Assert.That(cancellationTokenSource.Get(), Is.SameAs(cancellationTokenSource.Get()));
+
+                var tasks = new List<Task>
+                {
+                    Task.Run(() => Spin("A", cancellationTokenSource.Get().Token)),
+                    Task.Run(() => Spin("B", cancellationTokenSource.Get().Token)),
+                    Task.Run(() => Spin("C", cancellationTokenSource.Get().Token)),
+                    Task.Run(() => Spin("D", cancellationTokenSource.Get().Token))
+                };
+
+                // wait for all the tasks to start
+                while (tasks.Any(task => task.Status != TaskStatus.Running))
+                {
+                    Thread.Sleep(100);
+                }
+
+                cancellationTokenSource.Get().Cancel();
+
+                Task.WaitAll(tasks.ToArray());
+            }
+        }
+
+        private void Spin(string name, CancellationToken cancellationToken)
+        {
+            Log($@"[starting] : {name}");
+
+            while (!cancellationToken.IsCancellationRequested)
+            {
+                var timeout = Random.Next(5, 20) * 100;
+
+                Log($@"[sleeping] : {name} / timeout = {timeout}");
+
+                Thread.Sleep(timeout);
+            }
+
+            Log($@"[ending] : {name}");
+        }
+
+        private void Log(string message)
+        {
+            Console.WriteLine($@"{DateTime.Now:O} - {message}");
+        }
+    }
+}

Shuttle.Core.Threading/.package/package.nuspec

@@ -3,7 +3,7 @@
 <package>
 	<metadata>
 		<id>Shuttle.Core.Threading</id>
-		<version>11.0.2</version>
+		<version>11.1.1</version>
 		<authors>Eben Roux</authors>
 		<owners>Eben Roux</owners>
 		<license type="expression">BSD-3-Clause</license>

Shuttle.Core.Threading/CancellationTokenSource.cs

@@ -0,0 +1,26 @@
+using System;
+using System.Threading;
+
+namespace Shuttle.Core.Threading
+{
+    public class DefaultCancellationTokenSource : ICancellationTokenSource, IDisposable
+    {
+        private CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();
+
+        public CancellationTokenSource Get()
+        {
+            return _cancellationTokenSource;
+        }
+
+        public void Renew()
+        {
+            _cancellationTokenSource.Cancel();
+            _cancellationTokenSource = new CancellationTokenSource();
+        }
+
+        public void Dispose()
+        {
+            _cancellationTokenSource.Cancel();
+        }
+    }
+}

Shuttle.Core.Threading/ICancellationTokenSource.cs

@@ -0,0 +1,8 @@
+namespace Shuttle.Core.Threading
+{
+    public interface ICancellationTokenSource
+    {
+        System.Threading.CancellationTokenSource Get();
+        void Renew();
+    }
+}

Shuttle.Core.Threading/ProcessorThread.cs

@@ -15,7 +15,7 @@ public class ProcessorThread
         private readonly ILog _log;
         private readonly string _name;
         private readonly IProcessor _processor;
-        private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();
+        private readonly System.Threading.CancellationTokenSource _cancellationTokenSource = new System.Threading.CancellationTokenSource();
 
         private bool _started;
 

Shuttle.Core.Threading/Properties/AssemblyInfo.cs

@@ -13,10 +13,10 @@
 [assembly: AssemblyTitle(".NET Standard")]
 #endif
 
-[assembly: AssemblyVersion("11.0.2.0")]
+[assembly: AssemblyVersion("11.1.1.0")]
 [assembly: AssemblyCopyright("Copyright (c) 2021, Eben Roux")]
 [assembly: AssemblyProduct("Shuttle.Core.Threading")]
 [assembly: AssemblyCompany("Eben Roux")]
 [assembly: AssemblyConfiguration("Release")]
-[assembly: AssemblyInformationalVersion("11.0.2")]
+[assembly: AssemblyInformationalVersion("11.1.1")]
 [assembly: ComVisible(false)]