如何使用Delegate/Callback编写相同的代码？

Question

这是一个非常简单的例子，在互联网上可用异步/等待的概念，我不知道这个小逻辑可以如何使用开始/结束调用？ 我需要做的就是使用两种方法准备一个复杂的逻辑（Async/Await和代表），所以我想从基本工作流程开始。

int countCharacters() 
    { 

     int count = 0; 
     using (StreamReader reader= new StreamReader("D:\\Data.txt")) 
     { 
      string content = reader.ReadToEnd(); 
      count = content.Length; 
      Thread.Sleep(5000); 
     } 
      return count; 
    } 
    private async void btnProcessFIle_Click(object sender, EventArgs e) 
    { 
     Task<int> task = new Task<int>(countCharacters); 
     task.Start(); 
     int count = await task; 
     lblCount.Text = "No. of characters in file=" +Environment.NewLine+ count.ToString(); 


    } 

Answer 1

这是一个很简单的例子这是在异步/等待概念互联网上可用

这是一个非常糟糕的例子。

它使用任务构造函数和Start，这是一个明确的no-no（字面意思是没有有效的用例来做到这一点）。

它还在“异步示例”中的后台线程上同步使用文件系统。

如果你想的如何异步消费同步（例如，CPU绑定）代码的一个例子，那么这是一个更好的例子，几乎做同样的事情：

int countCharacters() 
{ 
    Thread.Sleep(5000); 
    return 13; 
} 

private async void btnProcessFIle_Click(object sender, EventArgs e) 
{ 
    var count = await Task.Run(() => countCharacters()); 
    lblCount.Text = "No. of characters in file=" + count; 
} 

注意，这是的示例如何异步调用UI线程的CPU绑定代码 - 它是而不是“异步概念”的示例。

我不知道如何使用开始/结束调用来实现这个小逻辑？

由于您的工作是在后台线程上同步工作，这实际上很简单; you can just use Delegate.BeginInvoke而不是创建自己的IAsyncResult（这是关于APM的非常困难的部分 - 如果您确实需要实现它，请参阅2007-03 issue of MSDN Magazine中的“实现CLR异步编程模型”）。

但因为你可以只使用Delegate.BeginInvoke，这是非常简单的：

private void btnProcessFIle_Click(object sender, EventArgs e) 
{ 
    var ui = SynchronizationContext.Current; 
    Func<int> d = countCharacters; 
    d.BeginInvoke(CountCharactersCallback, ui); 
} 

private void CountCharactersCallback(IAsyncResult ar) 
{ 
    var d = (Func<int>) ((AsyncResult) ar).AsyncDelegate; 
    var ui = (SynchronizationContext) ar.AsyncState; 
    try 
    { 
    var count = d.EndInvoke(ar); 
    ui.Post(CountCharactersComplete, count); 
    } 
    catch (Exception ex) 
    { 
    var edi = ExceptionDispatchInfo.Capture(ex); 
    ui.Post(CountCharactersError, state); 
    } 
} 

private void CountCharactersComplete(object state) 
{ 
    var count = (int) state; 
    lblCount.Text = "No. of characters in file=" + count; 
} 

private void CountCharactersError(object state) 
{ 
    var edi = (ExceptionDispatchInfo)state; 
    edi.Throw(); 
} 

注：

• CountCharactersCallback是 “裸露的回调”。从CountCharactersCallback传播的任何例外都表示灾难性错误。
• 尤其要注意的是，不要允许EndInvoke的例外传播出BeginInvoke回调。这是一个常见的错误。
• 我使用SynchronizationContext来同步回UI线程。这与await的行为相同。
• 我使用ExceptionDispatchInfo跨线程保留异常堆栈跟踪（不需要包装异常）。
• CountCharactersError只是直接在消息循环中引发异常。这与async void的行为相同。

Answer 2

功能的BeginInvoke是获得非UI线程里面的UI元素，所以你需要改变你的代码是这样的：

private async void btnProcessFIle_Click(object sender, EventArgs e) 
{ 
    var task = Task.Run(() => { 
    var count = countCharacters(); 
    lblCount.BeginInvoke((Action) (() => 
     { 
     lblCount.Text = "No. of characters in file=" +Environment.NewLine+ 
      count.ToString(); 
     })); 
    }); 

    await task; 

} 

Answer 3

代码，而异步/ AWAIT。你并不需要使用的BeginInvoke，因为你可以用TaskScheduler.FromCurrentSynchronizationContext()

int countCharacters() 
    { 

     int count = 0; 
     using (StreamReader reader= new StreamReader("D:\\Data.txt")) 
     { 
      string content = reader.ReadToEnd(); 
      count = content.Length; 
      Thread.Sleep(5000); 
     } 
      return count; 
    } 


    private void btnProcessFIle_Click(object sender, EventArgs e) 
    { 
     Task<int> task = new Task<int>(countCharacters); 
     task.Start(); 
     var uiScheduler = TaskScheduler.FromCurrentSynchronizationContext(); 
     task.ContinueWith(count =>{ 

       lblCount.Text = "No. of characters in file=" +Environment.NewLine+ count.ToString(); 
     }, uiScheduler); 
    } 

捕捉上下文如果你真的想使用的BeginInvoke我想你可以写

private void btnProcessFIle_Click(object sender, EventArgs e) 
    { 
     Task<int> task = new Task<int>(countCharacters); 
     task.Start(); 
     var uiScheduler = TaskScheduler.FromCurrentSynchronizationContext(); 
     task.ContinueWith(count =>{ 
       lblCount.BeginInvoke(()=>{ 
        lblCount.Text = "No. of characters in file=" +Environment.NewLine+ count.ToString(); 
       }); 

     }); 
    }