Hide task scheduler

src/core/Akka/Dispatch/Dispatchers.cs

@@ -185,10 +185,9 @@ public void ReadChannel()
     /// </summary>
     internal sealed class TaskSchedulerExecutor : ExecutorService
     {
-        /// <summary>
-        ///     The scheduler
-        /// </summary>
-        private TaskScheduler _scheduler;
+        readonly TaskFactory _factory;
+
+        readonly CancellationTokenSource _cts = new CancellationTokenSource();
 
         /// <summary>
         /// TBD
@@ -197,7 +196,7 @@ internal sealed class TaskSchedulerExecutor : ExecutorService
         /// <param name="scheduler">TBD</param>
         public TaskSchedulerExecutor(string id, TaskScheduler scheduler) : base(id)
         {
-            _scheduler = scheduler;
+            _factory = new TaskFactory(_cts.Token, TaskCreationOptions.HideScheduler, TaskContinuationOptions.None, scheduler);
         }
 
         // cache the delegate used for execution to prevent allocations
@@ -209,17 +208,16 @@ public TaskSchedulerExecutor(string id, TaskScheduler scheduler) : base(id)
         /// <param name="run">TBD</param>
         public override void Execute(IRunnable run)
         {
-            var t = new Task(Executor, run);
-            t.Start(_scheduler);
+            _factory.StartNew(Executor, run);
         }
 
         /// <summary>
         /// TBD
         /// </summary>
         public override void Shutdown()
         {
-            // clear the scheduler
-            _scheduler = null;
+            // cancel queued tasks
+            _cts.Cancel();
         }
     }