我有一个类,其中包含一个BlockingCollection<Task>
用于对多个任务进行排队以按顺序运行(先进先出)的类。
队列本身是在一个单独的长时间运行的任务上启动的。
public class TaskQueue
{
private readonly BlockingCollection<Task> _queue = new BlockingCollection<Task>();
public TaskQueue()
{
Task.Factory.StartNew(() =>
{
ProcessQueue();
}, TaskCreationOptions.LongRunning);
}
private async Task ProcessQueue()
{
foreach (var task in _queue.GetConsumingEnumerable())
await task;
}
...
}
当应用程序启动时,我创建了许多实例,TaskQueue
因为我需要为应用程序的不同组件使用不同的队列。
我看到的问题是,即使是ProcessQueue()
在 LongRunning 任务上启动的.NET Long Running Task
,但在任务的第一次等待之后,它会返回,即.NET ThreadPool Worker
不再是长时间运行的任务。
这会导致所有实例TaskQueue.ProcessQueue
结束.NET ThreadPool Workers
(在第一个等待之后),然后导致应用程序启动新任务的速度非常慢,因为它已经达到了并发运行的最大数量.NET ThreadPool Workers
(我相信这被设置为并发运行的数量)机器拥有的核心(在我的例子中是 8),之后它只会.NET ThreadPool Workers
每秒左右创建新的核心。
所以我的问题是:
- 有没有办法返回长时间运行的任务?
Task.Factory.StartNew
或者我应该用新线程替换?我相信这会解决问题,但不确定是否有更好的方法。