HeisenBugFix - ObjectDisposedException on CancellationTokenSource

Author: Martin Lercher

src/JsonRpc/ProcessScheduler.cs

@@ -10,7 +10,7 @@ public class ProcessScheduler : IScheduler
     {
         private readonly BlockingCollection<(RequestProcessType type, Func<Task> request)> _queue;
         private readonly CancellationTokenSource _cancel;
-        private Thread _queueThread;
+        private readonly Thread _queueThread;
 
         public ProcessScheduler()
         {
@@ -47,7 +47,6 @@ private void ProcessRequestQueue()
             {
                 while (true)
                 {
-                    if (_queueThread == null) return;
                     if (_queue.TryTake(out var item, Timeout.Infinite, token))
                     {
                         var (type, request) = item;
@@ -84,9 +83,8 @@ private void ProcessRequestQueue()
 
         public void Dispose()
         {
-            if (_queueThread == null) return;
-            _queueThread = null;
             _cancel.Cancel();
+            _queueThread.Join();
             _cancel.Dispose();
         }
     }