TaskScheduler -执行连续性

Question

在阅读了一些关于TaskScheduler (好文章)的文章之后，事实证明TaskScheduler可以：

1. 通过使用QueueTask方法来调度任务，在上面的示例中，该方法只是将Post的任务执行到所选的SynchronizationContext
2. 通过与当前正在运行的框架(SynchronizationContext)关联的较低级别调度程序进行调度。

2.与Task的Task方法有任何关系吗？我显然理解1.，但不明白2如何适用于TaskScheduler。在TaskScheduler的哪种方法中会发生这种情况？

Answer 1

通过与当前正在运行的框架(SynchronizationContext)关联的较低级别调度程序进行调度。

我想你把它弄混了。您可以使用给定的TaskScheduler并在其上执行一个延续，而不是相反。这正是您共享的帖子中的片段所做的：

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

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

它告诉Task.ContinueWith在更早的时候使用UI TaskScheduler (通过调用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;
    }
}