是否有使用自定义任务调度程序运行任务的正确方法？ .NET 框架

如何解决是否有使用自定义任务调度程序运行任务的正确方法？ .NET 框架

因此，我对使用任务调度程序和线程的总体情况仍然很陌生，但是在使用自定义任务调度程序时遇到了麻烦。不幸的是，我没有我所有的代码，但会尽量详细。

所以我的任务调度程序是基于这个 limited concurrency task scheduler。现在，我希望我的任务具有优先级，所以我还有一个单独的类来创建和存储一些并发队列，我正在使用这个 simple priority queue example。

所以我如何设置它是在我的任务调度程序的构造函数中，我为我想要的队列数量传递另一个参数：

public LimitedConcurrencyLevelTaskScheduler(int maxDegreeOfParallelism,int numberOfQueues)

然后构造函数用我想要的队列数创建一个优先级队列类的新实例。我真正从优先级队列类中使用的唯一方法是 TryAdd 和 TryTake。

现在，我对任务调度程序所做的更改主要是为了可以使用优先级队列类中的队列，而不是使用示例中的列表。我必须做的第一个改变是创建一个全新的方法来排队任务。我这样做是因为 QueueTask 没有采用多个参数的重载，而且我想创建一个键值对，其中包含优先级和任务。

protected sealed override void EnqueueTask(int Priority,Task task)
   {
      // Add the task to the list of tasks to be processed.  If there aren't enough
      // delegates currently queued or running to process tasks,schedule another.

   var item = KeyValuePair<int,Task> (Priority,task);
   lock (PriorityQueueClass._queues) //_queues are the concurrent queues that were created when I 
                                     //initialized my priority queue class. 
   {
       PriorityQueueClass.TryAdd(item);
       if (_delegatesQueuedOrRunning < _maxDegreeOfParallelism)
       {
           ++_delegatesQueuedOrRunning;
           NotifyThreadPoolOfPendingWork();
       }
   }


 }

我修改的唯一其他方法是 NotifyThreadPoolOfPendingWork()。此方法唯一真正的变化是我使用优先级队列类中的 TryTake（它将按优先级顺序遍历队列）来抓取一个项目并将其传递给 TryExecuteTask 方法：

 base.TryExecuteTask(item.Value); // item is a key-value pair,so the Value would be the task

这就是我遇到麻烦的地方。在一个单独的项目中，我有一个主程序（我为我的任务调度程序正确设置了我的引用），我在其中创建了一些任务，创建了我的调度程序，并尝试安排我的任务。

public static void Main()
{
// creates a new scheduler with 2 degrees of parralelism and 2 queues
LimitedConcurrencyLevelTaskScheduler lcts = new LimitedConcurrencyLevelTaskScheduler(2,2); 

//Create a few simple tasks
Task t1 = new Task(Action);  //the actions are just a method that prints some text to output window.
Task t2 = new Task(Action);  //I make the action in the main method,assume they are in here.
...

lcts.EnqueueTask(0,t1); //0 is the highest priority queue
lcts.EnqueueTask(1,t2); //1 is a lower priority queue
}

如果我运行会发生什么，它看起来像是在遍历所有代码，但是当它到达 EnqueueTask 方法中的 base.TryExecuteTask(item.Value) 时，它会抛出异常“可能不会调用执行任务先前排队到不同任务调度程序的任务”。

现在，我不确定这是否是启动调度程序的正确方法，因为我通常看到人们直接使用任务工厂或使用 task.Start()。我直接调用我的 EnqueueTask 方法，因为我目前没有看到更好的分配优先级的方法。但是如果我的想法有问题，或者如果有更好的方法来合并任务调度器和优先级队列类，那么我全神贯注。谢谢。

更新：需要坚持使用 .NET 4.6.1