Optimizing threading pool issues

yang-xiaodong · yang-xiaodong · commit 8692ebfd7c47 · 2019-03-21T23:49:14.000+08:00
diff --git a/src/DotNetCore.CAP/Processor/IDispatcher.Default.cs b/src/DotNetCore.CAP/Processor/IDispatcher.Default.cs
@@ -32,8 +32,8 @@ public Dispatcher(ILogger<Dispatcher> logger,
             _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)

Original file line number	Diff line number	Diff line change
`@@ -32,8 +32,8 @@ public Dispatcher(ILogger<Dispatcher> logger,`
`32`	`32`	`_sender = sender;`
`33`	`33`	`_executor = executor;`
`34`	`34`
`35`		`- Task.Factory.StartNew(Sending);`
`36`		`- Task.Factory.StartNew(Processing);`
	`35`	`+ Task.Factory.StartNew(Sending, _cts.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);`
	`36`	`+ Task.Factory.StartNew(Processing, _cts.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);`
`37`	`37`	`}`
`38`	`38`
`39`	`39`	`public void EnqueueToPublish(CapPublishedMessage message)`