12

我正在编写一个网络应用程序。

消息通过传输方式发送，如下所示：

Network.SendMessage (new FirstMessage() );

我可以注册一个事件处理程序，以便在此消息类型到达时调用，如下所示：

Network.RegisterMessageHandler<FirstMessage> (OnFirstMessageReceived);

事件被触发：

public void OnFirstMessageReceived(EventArgs<FirstMessageEventArgs> e)
{
}

我正在为我的联网应用程序编写一个自定义身份验证过程，它需要大约五条消息才能完成。

如果不使用任务并行库，我将被迫在前面的事件处理程序中编写每个过程的下一步，如下所示：

public void OnFirstMessageReceived(EventArgs<FirstMessageEventArgs> e)
{
     Network.SendMessage( new SecondMessage() );
}

public void OnSecondMessageReceived(EventArgs<SecondMessageEventArgs> e)
{
     Network.SendMessage( new ThirdMessage() );
}

public void OnThirdMessageReceived(EventArgs<ThirdMessageEventArgs> e)
{
     Network.SendMessage( new FourthMessage() );
}

public void OnFourthMessageReceived(EventArgs<FourthMessageEventArgs> e)
{
     // Authentication is complete
}

我不喜欢跳过源代码来编写其中一部分和一部分的想法。很难理解和编辑。

我听说任务并行库大大简化了这个解决方案。

但是，我使用任务并行库阅读的许多示例都与启动一系列活动任务有关。我所说的“活动”的意思是，每个任务都可以在显式调用时启动，如下所示：

public void Drink() {}
public void Eat()   {}
public void Sleep() {}

Task.Factory.StartNew(     () => Drink() )
            .ContinueWith( () => Eat()   )
            .ContinueWith( () => Sleep() );

这与我的基于事件的异步模式相反，其中每个事件处理程序方法仅在收到消息时调用。

换句话说，我不能做这样的事情（但我想）：

Task.Factory.StartNew(     () => OnFirstMessageReceived()  )
            .ContinueWith( () => OnSecondMessageReceived() )
            .ContinueWith( () => OnThirdMessageReceived()  )
            .ContinueWith( () => OnFourthMessageReceived() );

我读过这篇文章，但我不太明白。看来我需要做的TaskCompletionSource。如果我想从基于事件的异步模式（如上面的代码块）中创建一个任务，它会是什么样子？

4

2 回答 2

21

TaskCompletionSource 是对的，它是将 EAP（基于事件的异步模式）转换为 TPL 任务的关键。

这记录在这里：https ://docs.microsoft.com/en-us/dotnet/standard/parallel-programming/tpl-and-traditional-async-programming#exposing-complex-eap-operations-as-tasks

这是简化的代码：

public static class Extensions  
{
    public static Task<XDocument> GetRssDownloadTask(
        this WebClient client, Uri rssFeedUri)
    {
        // task completion source is an object, which has some state.
        // it gives out the task, which completes, when state turns "completed"
        // or else it could be canceled or throw an exception
        var tcs = new TaskCompletionSource<XDocument>(); 

        // now we subscribe to completed event. depending on event result
        // we set TaskCompletionSource state completed, canceled, or error
        client.DownloadStringCompleted += (sender, e) => 
        {
                  if(e.Cancelled) 
                  {
                      tcs.SetCanceled();
                  }
                  else if(null != e.Error)
                  {
                      tcs.SetException(e.Error);
                  }
                  else
                  { 
                      tcs.SetResult(XDocument.Parse(e.Result));
                  }
        };

        // now we start asyncronous operation
        client.DownloadStringAsync(rssFeedUri);
        // and return the underlying task immediately
        return tcs.Task;
    }
}

现在，您需要做的就是创建一系列操作，只需设置您的延续（目前这不是很舒服，C# 5 await 和 async 将对此有很大帮助）

所以，这段代码可以这样使用：

public static void Main()
{
    var client = new WebClient();

    client.GetRssDownloadTask(
        new Uri("http://blogs.msdn.com/b/ericlippert/rss.aspx"))
        .ContinueWith( t => {
            ShowXmlInMyUI(t.Result); // show first result somewhere
            // start a new task here if you want a chain sequence
        });

    // or start it here if you want to get some rss feeds simultaneously

    // if we had await now, we would add 
    // async keyword to Main method defenition and then

    XDocument feedEric = await client.GetRssDownloadTask(
        new Uri("http://blogs.msdn.com/b/ericlippert/rss.aspx"));
    XDocument feedJon = await client.GetRssDownloadTask(
        new Uri("http://feeds.feedburner.com/JonSkeetCodingBlog?format=xml"));
    // it's chaining - one task starts executing after 
    // another, but it is still asynchronous
}
于 2011-09-08T15:23:24.733 回答
3

Jeremy Likness 有一篇博文，标题为 Coroutines for Asynchronous Sequential Workflows using Reactive Extensions (Rx)，您可能会感兴趣。这是他试图回答的问题：

这个概念很简单：很多时候我们希望一组异步操作按顺序执行。也许您必须从​​服务加载列表，然后加载所选项目，然后触发动画。这可以通过链接完成的事件或嵌套 lambda 表达式来完成，但有没有更简洁的方法？

于 2011-09-08T01:33:10.520 回答