zoukankan      html  css  js  c++  java
  • TaskScheduler介绍【转】

    介绍

    task给我们带来了巨大的编程效率,在Task底层有一个TaskScheduler,它决定了task该如何被调度。
    而在.net framework中有两种系统定义Scheduler,第一个是Task默认的ThreadPoolTaskScheduler,还是一种就是SynchronizationContextTaskScheduler。

    ThreadPoolTaskScheduler

    这种scheduler机制是task的默认机制,而且从名字上也可以看到它是一种委托到ThreadPool的机制,刚好也从侧面说明task是基于ThreadPool基础上的封装
    看代码:

    protected internal override void QueueTask(Task task)
             {
                 if ((task.Options & TaskCreationOptions.LongRunning) != TaskCreationOptions.None)
                 {
                     new Thread(ThreadPoolTaskScheduler.s_longRunningThreadWork)
                     {
                         IsBackground = true
                     }.Start(task);
                     return;
                 }
                 bool forceGlobal = (task.Options & TaskCreationOptions.PreferFairness) > TaskCreationOptions.None;
                 ThreadPool.UnsafeQueueCustomWorkItem(task, forceGlobal);
             }
    

    从上面的代码中可以看到如下逻辑,如果当前Task上的TaskCreationOptions设置为LongRunning的话,这个task就会委托到Thread中去执行,这样的好处显而易见,如果长时间运行的task占用着ThreadPool的线程,这时候ThreadPool为了保证线程充足,会再次开辟一些Thread,如果耗时任务此时释放了,会导致ThreadPool线程过多,上下文切换频繁,所以这种情况下让Task在Thread中执行还是非常不错的选择,当然如果你不指定这个LongRunning的话,那就是在ThreadPool上执行

    SynchronizationContextTaskScheduler

    这是一个同步上下文的taskscheduler,原理就是把繁重的耗时工作丢给ThreadPool,然后将更新UI的操作丢给 UI线程的队列中,由UIThread来执行,看代码:

     protected internal override void QueueTask(Task task)
              {
                  this.m_synchronizationContext.Post(SynchronizationContextTaskScheduler.s_postCallback, task);
              }
    

    然后可以从s_postCallback上看到里面有一个Invoke函数

    public virtual void Post(SendOrPostCallback d, object state)
      {
          ThreadPool.QueueUserWorkItem(new WaitCallback(d.Invoke), state);
      }
    

    所以下面这段代码不阻塞UI线程

    private void button1_Click(object sender, EventArgs e)
             {
                 Task task = Task.Factory.StartNew(() =>
                 {
                     //复杂操作,等待10s
                     Thread.Sleep(10000);
    
                 }).ContinueWith((t) =>
                 {
                     button1.Text = "hello world";
                 }, TaskScheduler.FromCurrentSynchronizationContext());
             }
    

    转:https://www.cnblogs.com/huangxincheng/p/6781581.html

  • 相关阅读:
    tar打包如何不打包某一个文件夹(排除某些文件夹)
    第一个SpringBoot应用
    Linux(以RHEL7为例)下添加工作区的方法|| The Way To Add Workspace On Linux
    Linux(以centos7为例)下自动挂载NTFS硬盘
    基于Moodle的IT课程辅助教育平台搭建
    搭建基于python +opencv+Beautifulsoup+Neurolab机器学习平台
    如何利用word2013写图文并茂的博客
    如何安装win10+Red Hat Enterprise Linux双系统?
    课堂练习:ex 4-20
    实验二 函数重载、函数模板、简单类的定义和实现
  • 原文地址:https://www.cnblogs.com/fanfan-90/p/13658146.html
Copyright © 2011-2022 走看看