ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

c# – TaskScheduler – 执行continuation

2019-06-23 13:52:36  阅读:955  来源: 互联网

标签:c multithreading taskscheduler synchronizationcontext


在阅读了有关TaskScheduler(good article here)的一些内容后,发现TaskScheduler可以:

>计划任务 – 使用QueueTask方法,在上面的示例中,只将Posts任务执行发布到选定的SynchronizationContext
>通过与当前运行的框架(SynchronizationContext)关联的低级调度程序安排延续.

2.以任何方式与CotninueWith任务方法有关吗?我很明白1.但是不知道2.对于TaskScheduler来说是如何. TaskScheduler会采用什么方法?

解决方法:

Schedule continuations through the lower-level scheduler associated
with the currently running framework (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.InternalTask​​Queue:

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;
    }
}

标签:c,multithreading,taskscheduler,synchronizationcontext
来源: https://codeday.me/bug/20190623/1271455.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有