Renamed IThreadPool to IDispatcher because it's more appropriate

Author: BladeBreaker

DispatchQueue/ConcurrentQueue.cs

@@ -18,7 +18,7 @@ public class ConcurrentQueue : IDispatchQueue
  /// <summary>
  /// Thread pool interface to submit work to
  /// </summary>
- private readonly IThreadPool mThreadPool;
+ private readonly IDispatcher mDispatcher;
 
  #endregion
 
@@ -29,10 +29,10 @@ public class ConcurrentQueue : IDispatchQueue
  /// Constructs a concurrent queue which will schedule work onto the passed thread pool
  /// </summary>
  /// <param name="threadPool">The thread pool that this SerialQueue will post work to. Must not be null</param>
- public ConcurrentQueue(IThreadPool threadPool)
+ public ConcurrentQueue(IDispatcher dispatcher)
  {
- mThreadPool = threadPool ?? throw new ArgumentNullException("threadPool");
- mTimerQueue = new TimerQueue(this, threadPool);
+ mDispatcher = dispatcher ?? throw new ArgumentNullException("dispatcher");
+ mTimerQueue = new TimerQueue(this, dispatcher);
  }
 
  #endregion
@@ -47,7 +47,7 @@ public ConcurrentQueue(IThreadPool threadPool)
  /// <param name="work">Delegate which will perform the work. Must not be null</param>
  public void DispatchAsync(object? context, WaitCallback work)
  {
- mThreadPool.QueueWorkItem(work, context);
+ mDispatcher.QueueWorkItem(work, context);
  }
 
 

DispatchQueue/IThreadPool.cs renamed to DispatchQueue/IDispatcher.cs

@@ -2,7 +2,7 @@
 
 namespace Dispatch
 {
- public interface IThreadPool
+ public interface IDispatcher
  {
  public void QueueWorkItem(System.Threading.WaitCallback work, object? context);
  }

DispatchQueue/ManagedThreadPool.cs renamed to DispatchQueue/ManagedThreadPoolDispatcher.cs

@@ -2,9 +2,9 @@
 
 namespace Dispatch
 {
- public class ManagedThreadPool : IThreadPool
+ public class ManagedThreadPoolDispatcher : IDispatcher
  {
- public ManagedThreadPool()
+ public ManagedThreadPoolDispatcher()
  {
  }
 

DispatchQueue/SerialQueue.cs

@@ -41,7 +41,7 @@ private struct WorkData
  /// <summary>
  /// Thread pool interface to submit work to
  /// </summary>
- private readonly IThreadPool mThreadPool;
+ private readonly IDispatcher mDispatcher;
 
 
  /// <summary>
@@ -79,10 +79,10 @@ private struct WorkData
  /// Constructs a SerialQueue which will schedule work onto the passed thread pool
  /// </summary>
  /// <param name="threadPool">The thread pool that this SerialQueue will post work to. Must not be null</param>
- public SerialQueue(IThreadPool threadPool)
+ public SerialQueue(IDispatcher dispatcher)
  {
- mThreadPool = threadPool ?? throw new ArgumentNullException("threadPool");
- mTimerQueue = new TimerQueue(this, threadPool);
+ mDispatcher = dispatcher ?? throw new ArgumentNullException("dispatcher");
+ mTimerQueue = new TimerQueue(this, dispatcher);
  mOnExecuteWorkItemFunction = OnExecuteWorkItem;
  }
 
@@ -156,7 +156,7 @@ private void AttemptDequeue()
  if (mQueue.TryDequeue(out WorkData work))
  {
  mCurrentWork = work;
- mThreadPool.QueueWorkItem(mOnExecuteWorkItemFunction, null);
+ mDispatcher.QueueWorkItem(mOnExecuteWorkItemFunction, null);
  }
  }
  }

DispatchQueue/TimerQueue.cs

@@ -41,7 +41,7 @@ public int Compare(TimerQueueData x, TimerQueueData y)
  private readonly TimerQueueDataComparer mTimerQueueDataComparer = new TimerQueueDataComparer();
 
  private readonly IDispatchQueue mDispatchQueue;
- private readonly IThreadPool mThreadPool;
+ private readonly IDispatcher mDispatcher;
 
  //mTimerQueueData is used across multiple threads and must be locked
  // all TimerQueueData's added to this list will be ordered on insertion from oldest TargetTime to earliest
@@ -55,10 +55,10 @@ public int Compare(TimerQueueData x, TimerQueueData y)
 
  #region Constructors
 
- public TimerQueue(IDispatchQueue dispatchQueue, IThreadPool threadPool)
+ public TimerQueue(IDispatchQueue dispatchQueue, IDispatcher dispatcher)
  {
  mDispatchQueue = dispatchQueue ?? throw new ArgumentNullException("dispatchQueue");
- mThreadPool = threadPool ?? throw new ArgumentNullException("threadPool");
+ mDispatcher = dispatcher ?? throw new ArgumentNullException("dispatcher");
 
  mTimer = new Timer(OnTimerExecute);
 
@@ -90,7 +90,7 @@ public void DispatchAfter(DateTime when, object? context, WaitCallback work)
  };
 
  // boxed "data" but ... I don't see an alternative
- mThreadPool.QueueWorkItem(mScheduleWorkForExecutionCallback, data);
+ mDispatcher.QueueWorkItem(mScheduleWorkForExecutionCallback, data);
  }
 
  #endregion