同步上下文 SynchronizationContext 學習筆記

提供在各種同步模型中傳播同步上下文的基本功能。，同步上下文的工作就是確保調用在正確的線程上執行。

 

同步上下文的基本操作

Current 獲取當前同步上下文

var context = SynchronizationContext.Current;

Send 一個同步消息調度到一個同步上下文。

 

SendOrPostCallback callback = o =>
                                              {
                                                  //TODO:
                                              };
context.Send(callback,null);

send調用后會阻塞直到調用完成。

Post 將異步消息調度到一個同步上下文。

SendOrPostCallback callback = o =>
                                              {
                                                  //TODO:
                                              };
context.Post(callback,null);

和send的調用方法一樣，不過Post會啟動一個線程來調用，不會阻塞當前線程。

 

使用同步上下文來更新UI內容

無論WinFroms和WPF都只能用UI線程來更新界面的內容

常用的調用UI更新方法是Inovke（WinFroms）：

private void button_Click(object sender, EventArgs e)
{
       ThreadPool.QueueUserWorkItem(BackgroudRun);
}

private void BackgroudRun2(object state)
{
            this.Invoke(new Action(() =>
                                       {
                                           label1.Text = "Hello Invoke";
                                       }));
}

 

 

使用同步上下文也可以實現相同的效果，

WinFroms和WPF繼承了SynchronizationContext，使同步上下文能夠在UI線程或者Dispatcher線程上正確執行

System.Windows.Forms. WindowsFormsSynchronizationContext
System.Windows.Threading. DispatcherSynchronizationContext

 

調用方法如下：

private void button_Click(object sender, EventArgs e)
{
           var context = SynchronizationContext.Current; //獲取同步上下文
           Debug.Assert(context != null);
           ThreadPool.QueueUserWorkItem(BackgroudRun, context); 
}


private void BackgroudRun(object state)
{
    var context = state as SynchronizationContext; //傳入的同步上下文
    Debug.Assert(context != null);
    SendOrPostCallback callback = o =>
                                      {
                                          label1.Text = "Hello SynchronizationContext";
                                      };
    context.Send(callback,null); //調用
}

使用.net4.0的Task 可以簡化成

private void button_Click(object sender, EventArgs e)
{
            var  scheduler = TaskScheduler.FromCurrentSynchronizationContext(); // 創建一個SynchronizationContext 關聯的 TaskScheduler
            Task.Factory.StartNew(() => label1.Text = "Hello TaskScheduler", CancellationToken.None,
                                  TaskCreationOptions.None, scheduler);
}