C#线程间通信的异步机制

        delegate void DoWork();
        private void button1_Click(object sender, EventArgs e)
        {
            //更新状态,添加到Listbox 中
            AddValue("Asynchronous Start.");
            //使用委托来调用异步方法
            DoWork work = DoWorkMethod;
            work.BeginInvoke(OnWorkCallback, work);
        }

        void OnWorkCallback(IAsyncResult asyncResult)
        {
            DoWork work = asyncResult.AsyncState as DoWork;
            if (work != null)
            {
                work.EndInvoke(asyncResult);
            }
            //(1)方法:调用Control控件的Invoke
            //Action<string> asyncUpdateState = UpdateStatus; //Action<string> 介绍=> 附1
            //Invoke(asyncUpdateState, "1:Asynchronous End.");

            //(2)方法:直接在异步调用的线程下
            UpdateStatus("2:Asynchronous End.");
        }

        void UpdateStatus(string input)
        {
            //把你需要通知的控件Control 赋值给ISynchronizeInvoke
            //来实现线程间的通信
            ISynchronizeInvoke async = this.listBoxStatus;
            //使用(1)方法,InvokeRequired == false ,来源当前(Window Form)主线程
            if (async.InvokeRequired == false)
                AddValue(input);
            else// 使用(2)方法 == true ,来源其他线程(异步)
            {
                Action<string> action = new Action<string>(status =>
                {
                    AddValue(status);
                });
                //调用ISynchronizeInvoke 提供的Invoke 同步方法,阻碍线程,直到调用结束
                //也可以使用ISynchronizeInvoke 提供的异步BeginInvoke/EndInvoke方法来实现调用.
                async.Invoke(action, new object[] { input });
            }
        }

        void AddValue(string input)
        {
            this.listBoxStatus.Items.Add(string.Format("[(#{2}){0}]Context is null:{1}", input, Thread.CurrentContext == null, Thread.CurrentThread.ManagedThreadId));
        }
        void DoWorkMethod()
        {
            Thread.Sleep(3000);//模拟耗时工作
        }

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

　public virtual void Send(SendOrPostCallback d, object state)
　{
　　　d(state);
　}

      delegate void DoWork();
　　　private void button1_Click(object sender, EventArgs e)
　　　{
　　　　　//System.Windows.Forms.Form 自动的创建默认的同步上下文对象,
　　　　　//直接的获取当前的同步上下文对象
　　　　　SynchronizationContext context = SynchronizationContext.Current;
　　　　　//更新状态,添加到Listbox 中
　　　　　AddValue<string>("Asynchronous Start.");
　　　　　//使用委托来调用异步方法
　　　　　　DoWork work = DoWorkMethod;
　　　　　　work.BeginInvoke(OnWorkCallback, context);

　　　　}
　　　　void OnWorkCallback(IAsyncResult asyncResult)
　　　　{
　　　　　　AsyncResult async = (AsyncResult)asyncResult;
　　　　　　DoWork work = (DoWork)async.AsyncDelegate;
　　　　　　work.EndInvoke(asyncResult);
　　　　　　
　　　　　　//更新状态
　　　　　　UpdateStatus("Asynchronous End.", asyncResult.AsyncState);
　　　　}
　　　　void UpdateStatus(object input,object syncContext)
　　　　{
　　　　　　//获取主线程(Window Form)中同步上下文对象
　　　　　　SynchronizationContext context = syncContext as SynchronizationContext;
　　　　　　//使用SynchronizationContext 类中异步Post 方法
　　　　　　SendOrPostCallback callback = new SendOrPostCallback(p => {
　　　　　　　　AddValue<object>(p);
　　　　　　});
　　　　　　context.Post(callback, input);//Post 为异步,Send 为同步

　　　　}
　　　　void AddValue<T>(T input)
　　　　{
　　　　　　this.listBoxStatus.Items.Add(string.Format("[(#{2}){0}]Context is null:{1}", input, Thread.CurrentContext == null, Thread.CurrentThread.ManagedThreadId));
　　　　}
　　　　void DoWorkMethod()
　　　　{
　　　　　　Thread.Sleep(3000);//模拟耗时工作
　　　　}

  static class Program
　{
　　　static void Main()
　　　{
　　　　　Output("Main Thread Start.");
　　　　　//为主线程创建Synchronization Context
　　　　　var context = new SynchronizationContext();
　　　　　//开始一个新线程
　　　　　Thread threadB = new Thread(work);
　　　　　　threadB.Start(context);

　　　　　　Console.Read();
　　　　}
　　　　static void work(object context)
　　　　{
　　　　　　Output("Thread B");

　　　　　　//获取主线程中的同步上下文对象
　　　　　　SynchronizationContext sc = context as SynchronizationContext;

　　　　　　//异步的方式和主线程通信,并发送"Hello World".
　　　　　　sc.Post(new SendOrPostCallback(p =>
　　　　　　{
　　　　　　　　Output(p);
　　　　　　}), "Hello World");
　　　　}
　　　　static void Output(object value)
　　　　{
　　　　　　Console.WriteLine("[ThreadID:#{0}]{1}", Thread.CurrentThread.ManagedThreadId, value);
　　　　}
　　}

  public class MySynchronizedClass
　{
　　　private AsyncOperation operation;
　　　public event EventHandler somethingHappened;
　　　public MySynchronizedClass()
　　　{
　　　　　//创建AsyncOperation 对象,并把当前线程的同步上下文保持到AsyncOperation中.
　　　　　operation = AsyncOperationManager.CreateOperation(null);

　　　　　　Thread workerThread = new Thread(new ThreadStart(DoWork));
　　　　　　workerThread.Start();
　　　　}

　　　　private void DoWork()
　　　　{
　　　　　　SendOrPostCallback callback = new SendOrPostCallback(state =>
　　　　　　　{
　　　　　　　　　EventHandler handler = somethingHappened;

　　　　　　　　　if (handler != null)
　　　　　　　　　{
　　　　　　　　　　　handler(this, EventArgs.Empty);
　　　　　　　　　}
　　　　　　　});

　　　　　　operation.Post(callback, null);
　　　　　　//注意1
　　　　　　operation.OperationCompleted();
　　　　}
　　}