任务调度器 - 执行连续任务

Question

经过阅读关于 TaskScheduler 的一些资料（这里有一篇不错的文章），我们可以得知 TaskScheduler 可以：

1. 调度任务 - 通过使用 QueueTask 方法，在上面的示例中，它只是将任务执行 Post 到选择的 SynchronizationContext

2. 通过当前运行框架（SynchronizationContext）关联的低级调度程序来安排后续操作。

那么，2. 是否与 Task 中的 CotninueWith 方法有任何关系呢？我当然理解 1.，但不明白 2. 如何适用于 TaskScheduler。在 TaskScheduler 的哪个方法中会发生这种情况？

- user4205580

---

好的，有一些Task.ContinueWith重载函数可以接受一个TaskScheduler参数，以便由该调度程序安排继续执行...这是你想要的吗？ - Jon Skeet

Answer 1

通过与当前正在运行的框架相关联的较低级别调度程序（SynchronizationContext），安排延续操作。

我想你有点混淆了。您可以使用给定的TaskScheduler并在其上执行延续操作，而不是反过来。这正是您分享的文章中的代码片段所做的事情。

var ui = TaskScheduler.FromCurrentSynchronizationContext(); 
var tf = Task.Factory; 

blendedImage.ContinueWith(_ => 
{ 
    pictureBox1.Image = blendedImage.Result; 
}, ui); 

它告诉Task.ContinueWith使用UITaskScheduler（通过调用TaskScheduler.FromCurrentSynchronizationContext()提供）来在特定上下文中调用继续任务，这次的上下文是UI消息循环。如果您真的想深入了解细节，当将TaskScheduler传递给ContinueWith时，它最终会传递给一个名为StandardTaskContinuation的类，该类具有以下Run方法，最终会调用TaskScheduler.InternalTaskQueue。

internal void ScheduleAndStart(bool needsProtection)
{
    if (needsProtection)
    {
        if (!this.MarkStarted())
        {
            return;
        }
    }
    else
    {
        this.m_stateFlags |= 65536;
    }
    if (Task.s_asyncDebuggingEnabled)
    {
        Task.AddToActiveTasks(this);
    }
    if (AsyncCausalityTracer.LoggingOn && 
       (this.Options & (TaskCreationOptions)512) == TaskCreationOptions.None)
    {
        AsyncCausalityTracer.TraceOperationCreation(
            CausalityTraceLevel.Required, this.Id, "Task: " +
            ((Delegate)this.m_action).Method.Name, 0uL);
    }
    try
    {
        this.m_taskScheduler.InternalQueueTask(this);
    }
    catch (ThreadAbortException exceptionObject)
    {
        this.AddException(exceptionObject);
        this.FinishThreadAbortedTask(true, false);
    }
    catch (Exception arg_93_0)
    {
        TaskSchedulerException ex = new TaskSchedulerException(arg_93_0);
        this.AddException(ex);
        this.Finish(false);
        if ((this.Options & (TaskCreationOptions)512) == TaskCreationOptions.None)
        {
            this.m_contingentProperties.m_exceptionsHolder.MarkAsHandled(false);
        }
        throw ex;
    }
}

- Yuval Itzchakov