From b933a07d89ff802dd2d29a6dd208d453cab84c94 Mon Sep 17 00:00:00 2001
From: James Watson <james@weareadaptive.com>
Date: Mon, 5 Sep 2016 00:10:47 +0100
Subject: [PATCH] Support passing a thread factory to
 AgentRunning.startOnThread

---
 src/Adaptive.Agrona/Adaptive.Agrona.csproj        |  3 +++
 src/Adaptive.Agrona/Concurrent/AgentRunner.cs     | 15 +++++++++++++++
 .../Concurrent/DefaultThreadFactory.cs            | 12 ++++++++++++
 src/Adaptive.Agrona/Concurrent/IThreadFactory.cs  | 10 ++++++++++
 4 files changed, 40 insertions(+)
 create mode 100644 src/Adaptive.Agrona/Concurrent/DefaultThreadFactory.cs
 create mode 100644 src/Adaptive.Agrona/Concurrent/IThreadFactory.cs

diff --git a/src/Adaptive.Agrona/Adaptive.Agrona.csproj b/src/Adaptive.Agrona/Adaptive.Agrona.csproj
index 9a963368..9928db60 100644
--- a/src/Adaptive.Agrona/Adaptive.Agrona.csproj
+++ b/src/Adaptive.Agrona/Adaptive.Agrona.csproj
@@ -85,12 +85,14 @@
     <Compile Include="Concurrent\Broadcast\CopyBroadcastReceiver.cs" />
     <Compile Include="Concurrent\Broadcast\RecordDescriptor.cs" />
     <Compile Include="Concurrent\BusySpinIdleStrategy.cs" />
+    <Compile Include="Concurrent\DefaultThreadFactory.cs" />
     <Compile Include="Concurrent\Errors\DistinctErrorLog.cs" />
     <Compile Include="Concurrent\Errors\ErrorReader.cs" />
     <Compile Include="Concurrent\Errors\IErrorConsumer.cs" />
     <Compile Include="Concurrent\IEpochClock.cs" />
     <Compile Include="Concurrent\IAgent.cs" />
     <Compile Include="Concurrent\IAtomicBuffer.cs" />
+    <Compile Include="Concurrent\IThreadFactory.cs" />
     <Compile Include="Concurrent\Status\AtomicCounter.cs" />
     <Compile Include="Concurrent\Status\AtomicLongPosition.cs" />
     <Compile Include="Concurrent\Status\CountersManager.cs" />
@@ -99,6 +101,7 @@
     <Compile Include="Concurrent\SleepingIdleStrategy.cs" />
     <Compile Include="Concurrent\SpinWaitIdleStrategy.cs" />
     <Compile Include="Concurrent\Status\UnsafeBufferPosition.cs" />
+    <Compile Include="Concurrent\StopwatchClock.cs" />
     <Compile Include="Concurrent\SystemNanoClock.cs" />
     <Compile Include="Concurrent\UnsafeBuffer.cs" />
     <Compile Include="Concurrent\IIdleStrategy.cs" />
diff --git a/src/Adaptive.Agrona/Concurrent/AgentRunner.cs b/src/Adaptive.Agrona/Concurrent/AgentRunner.cs
index 5e9ad1d0..dabf793d 100644
--- a/src/Adaptive.Agrona/Concurrent/AgentRunner.cs
+++ b/src/Adaptive.Agrona/Concurrent/AgentRunner.cs
@@ -46,6 +46,7 @@ public AgentRunner(IIdleStrategy idleStrategy, ErrorHandler errorHandler, Atomic
         /// Start the given agent runner on a new thread.
         /// </summary>
         /// <param name="runner"> the agent runner to start </param>
+        /// <returns>  the new thread that has been started.</returns>
         public static Thread StartOnThread(AgentRunner runner)
         {
             var thread = new Thread(runner.Run)
@@ -56,6 +57,20 @@ public static Thread StartOnThread(AgentRunner runner)
             return thread;
         }
 
+        /// <summary>
+        /// Start the given agent runner on a new thread.
+        /// </summary>
+        /// <param name="runner"> the agent runner to start </param>
+        /// <param name="threadFactory"> the factory to use to create the thread.</param>
+        /// <returns>  the new thread that has been started.</returns>
+        public static Thread StartOnThread(AgentRunner runner, IThreadFactory threadFactory)
+        {
+            var thread = threadFactory.NewThread(runner.Run);
+            thread.Name = runner.Agent().RoleName();
+            thread.Start();
+            return thread;
+        }
+
         /// <summary>
         /// The <seealso cref="IAgent"/> who's lifecycle is being managed.
         /// </summary>
diff --git a/src/Adaptive.Agrona/Concurrent/DefaultThreadFactory.cs b/src/Adaptive.Agrona/Concurrent/DefaultThreadFactory.cs
new file mode 100644
index 00000000..2f9551e3
--- /dev/null
+++ b/src/Adaptive.Agrona/Concurrent/DefaultThreadFactory.cs
@@ -0,0 +1,12 @@
+using System.Threading;
+
+namespace Adaptive.Agrona.Concurrent
+{
+    public class DefaultThreadFactory : IThreadFactory
+    {
+        public Thread NewThread(ThreadStart runner)
+        {
+            return new Thread(runner);
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/Adaptive.Agrona/Concurrent/IThreadFactory.cs b/src/Adaptive.Agrona/Concurrent/IThreadFactory.cs
new file mode 100644
index 00000000..031861e4
--- /dev/null
+++ b/src/Adaptive.Agrona/Concurrent/IThreadFactory.cs
@@ -0,0 +1,10 @@
+using System;
+using System.Threading;
+
+namespace Adaptive.Agrona.Concurrent
+{
+    public interface IThreadFactory
+    {
+        Thread NewThread(ThreadStart runner);
+    }
+}
\ No newline at end of file