C# SynchronizationContext以及Send和Post使用解讀

更新時(shí)間：2023年05月04日 10:25:34 作者：你の貓

這篇文章主要介紹了C# SynchronizationContext以及Send和Post使用解讀，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

C# SynchronizationContext及Send和Post使用

1、(SynchronizationContext)同步上下文的作用

SynchronizationContext其實(shí)就是實(shí)現(xiàn)線程之間通訊的。

2、創(chuàng)建(SynchronizationContext)同步上下文的方法

1）直接new創(chuàng)建一個(gè)SynchronizationContext同步上下文對(duì)象。
2）winform程序通過(guò)SynchronizationContext.Current獲取UI線程的同步上下文對(duì)象。
3）AsyncOperation和AsyncOperationManager類來(lái)操作同步上下文對(duì)象，不直接訪問(wèn)同步上下文對(duì)象(SynchronizationContext)，推薦這程方法。

3、(SynchronizationContext)同步上下文的Send和Post方法

看了一些解釋Send和Post方法，感覺(jué)弄得很復(fù)雜，我感覺(jué)其實(shí)簡(jiǎn)單來(lái)說(shuō)，

1）Send方法就是同步調(diào)用，在當(dāng)前線程上調(diào)用委托。
2）Post方法就是異步調(diào)用，在線程池中的線程調(diào)用委托。

4、示例代碼

1）(SynchronizationContext)同步上下文使用示例代碼

using System;
using System.Threading;
namespace SynchronizationContextExample
{
? ? public class MySynchronizedClass
? ? {
? ? ? ? private Thread workerThread;
? ? ? ? private SynchronizationContext context;
? ? ? ? public event EventHandler SomethingHappened;
? ? ? ? public MySynchronizedClass()
? ? ? ? {
? ? ? ? ?//獲取當(dāng)前SynchronizationContext非常重要對(duì)象在構(gòu)造函數(shù)中。我們想要的
? ? ? ? ?//屬于線程的SynchronizationContext對(duì)象
? ? ? ? ?//這個(gè)對(duì)象正在被創(chuàng)建。
? ? ? ? ?//context= SynchronizationContext.Current;當(dāng)前線程可能沒(méi)有SynchronizationContext對(duì)象;該線程尚未為設(shè)置SynchronizationContext對(duì)象。
? ? ? ? ?//如果是這樣，我們可以通過(guò)創(chuàng)建SynchronizationContext來(lái)簡(jiǎn)化
? ? ? ? ? ? if(context == null)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? context = new SynchronizationContext();
? ? ? ? ? ? }
? ? ? ? ? ? workerThread = new Thread(new ThreadStart(DoWork));
? ? ? ? ? ? workerThread.Start();
? ? ? ? }
? ? ? ? private void DoWork()
? ? ? ? {
? ? ? ? ? ? context.Post(new SendOrPostCallback(delegate(object state)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? EventHandler handler = SomethingHappened;
? ? ? ? ? ? ? ? if(handler != null)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? handler(this, EventArgs.Empty);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }), null);
? ? ? ? }
? ? }
}

2）使用AsyncOperation和AsyncOperationManager類示例代碼

using System;
using System.Threading;
using System.ComponentModel;
namespace SynchronizationContextExample
{
? ? public class MySynchronizedClass
? ? {
? ? ? ? private Thread workerThread;
? ? ? ? private AsyncOperation operation;
? ? ? ? public event EventHandler SomethingHappened;
? ? ? ? public MySynchronizedClass()
? ? ? ? {
? ? ? ? ? ? operation = AsyncOperationManager.CreateOperation(null);
? ? ? ? ? ? workerThread = new Thread(new ThreadStart(DoWork));
? ? ? ? ? ? workerThread.Start();
? ? ? ? }
? ? ? ? private void DoWork()
? ? ? ? {
? ? ? ? ? ? operation.Post(new SendOrPostCallback(delegate(object state)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? EventHandler handler = SomethingHappened;
? ? ? ? ? ? ? ? if(handler != null)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? handler(this, EventArgs.Empty);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }), null);
? ? ? ? ? ? operation.OperationCompleted();
? ? ? ? }
? ? }
}

C#同步上下文SynchronizationContext學(xué)習(xí)筆記

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

同步上下文的基本操作

Current 獲取當(dāng)前同步上下文

var context = SynchronizationContext.Current;

Send 一個(gè)同步消息調(diào)度到一個(gè)同步上下文。

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

send調(diào)用后會(huì)阻塞直到調(diào)用完成。
Post 將異步消息調(diào)度到一個(gè)同步上下文。

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

和send的調(diào)用方法一樣，不過(guò)Post會(huì)啟動(dòng)一個(gè)線程來(lái)調(diào)用，不會(huì)阻塞當(dāng)前線程。

使用同步上下文來(lái)更新UI內(nèi)容

無(wú)論WinFroms和WPF都只能用UI線程來(lái)更新界面的內(nèi)容

常用的調(diào)用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";
? ? ? ? ? ? ? ? ? ? ? ?}));
}

使用同步上下文也可以實(shí)現(xiàn)相同的效果，WinFroms和WPF繼承了SynchronizationContext，使同步上下文能夠在UI線程或者Dispatcher線程上正確執(zhí)行

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

調(diào)用方法如下：

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); //調(diào)用
}

使用.net4.0的Task 可以簡(jiǎn)化成

private void button_Click(object sender, EventArgs e)
{
? ? ? ? ? ? var ?scheduler = TaskScheduler.FromCurrentSynchronizationContext(); // 創(chuàng)建一個(gè)SynchronizationContext 關(guān)聯(lián)的 TaskScheduler
? ? ? ? ? ? Task.Factory.StartNew(() => label1.Text = "Hello TaskScheduler", CancellationToken.None,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? TaskCreationOptions.None, scheduler);
}