假设我希望创建一个自定义TaskScheduler,但在它内部,如果某些条件不适用,则返回到默认状态。我该怎么做?
例如。
protected override void QueueTask(Task task) {
if (/* some condition */) {
/* schedule task manually, does not matter */
}
/* queue task on default -- how? */
}
protected override IEnumerable<Task> GetScheduledTasks() {
return Enumerable.Concat(/* my tasks */, /* tasks from default -- how? */);
}发布于 2014-03-23 05:48:11
我不认为你能(或应该)做这件事,即使你求助于反思技巧。理论上,您需要从现有的非抽象任务调度器(如TaskScheduler )中派生自定义任务调度器( ThreadPoolTaskScheduler )。
但是,您不能这样做,因为TPL中的所有非抽象实现 of TaskScheduler不是private就是internal。
如果使用TaskScheduler.QueueTask,可能很容易将调用转发到Task.Start
protected override void QueueTask(Task task) {
if (/* some condition */) {
/* schedule task manually, does not matter */
}
/* queue task on default -- how? */
task.Start(TaskScheduler.Default);
}但是,你也不能这样做。Task.Start在内部调用TaskScheduler.QueueTask,这将导致无限递归。
此外,Task对象在Task.Start中存储对任务调度程序的引用。因此,如果您使用反射来调用ThreadPoolTaskScheduler.QueueTask,它将中断任务与其任务调度程序之间的连接。
因此,QueueTask、GetScheduledTasks和其他一些TaskScheduler方法被声明为protected是有原因的。如果您想实现自定义任务调度器,则必须提供完整的实现。
https://stackoverflow.com/questions/22583841
复制相似问题