Optimizing threading pool issues

8692ebfd · Savorboard · 7cebd84f · 8692ebfd
Commit 8692ebfd authored Mar 21, 2019 by Savorboard
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

IDispatcher.Default.cs src/DotNetCore.CAP/Processor/IDispatcher.Default.cs +2 -2

No files found.
--- a/src/DotNetCore.CAP/Processor/IDispatcher.Default.cs
+++ b/src/DotNetCore.CAP/Processor/IDispatcher.Default.cs
@@ -32,8 +32,8 @@ namespace DotNetCore.CAP.Processor
            _sender = sender;
            _executor = executor;

-            Task.Factory.StartNew(Sending);
-            Task.Factory.StartNew(Processing);
+            Task.Factory.StartNew(Sending, _cts.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);
+            Task.Factory.StartNew(Processing, _cts.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);
        }

        public void EnqueueToPublish(CapPublishedMessage message)