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

上一篇:C#(ThreadPool)线程池的详解及使用范例


下一篇:Exchanger--线程执行过程中交换数据