如何轻松地将两个异步请求链接在一起?

 public Image GetDilbert()
 {
     var   dilbertUrl  = new Uri(@"http://dilbert.com");
     var   request     = WebRequest.CreateDefault(dilbertUrl);
     var   webHandle   = new ManualResetEvent(false /* nonsignaled */);
     Image returnValue = null;

     request.BeginGetResponse(ar => 
     {  
          //inside AsynchCallBack method for request.BeginGetResponse()
          var response = (HttpWebResponse) request.EndGetResponse(ar); 

          string html;  
          using (var receiveStream = response.GetResponseStream())
          using (var readStream    = new StreamReader(  receiveStream
                                                      , Encoding.UTF8))
          {
             html = readStream.ReadToEnd();
          }

          var re=new Regex(@"dyn/str_strip/[0-9/]+/[0-9]*\.strip\.gif");
          var match=re.Match(html);

          var imgHandle = new ManualResetEvent(true /* signaled  */);

          if (match.Success) 
          {   
              imgHandle.Reset();              

              var groups = match.Groups;
              var s = (groups.Count>0) ?groups[groups.Count-1].ToString()
                                       :match.Value;
              var _uri   = new Uri(dilbertUrl, s);
              var imgReq = WebRequest.CreateDefault(_uri);

              imgReq.BeginGetResponse(ar2 => 
              {  var imageRsp= (HttpWebResponse)imgReq.EndGetResponse(ar2);

                 using (var imgStream=imageRsp.GetResponseStream())
                 { 
                    var im=(Image)Image.FromStream(imgStream,true,true);
                    returnValue = (Image) im.Clone();
                 }    

                 imgHandle.Set();           
              }, new object() /*state*/);
          }      

          imgHandle.WaitOne();
          webHandle.Set();  
     }, new object() /* state */);

     webHandle.WaitOne();  
     return returnValue;      
 }

对于begin/endgetdilbert()方法,可以使用 Future<T> 如上所述 http://blogs.msdn.com/pfxteam/archive/2008/02/29/7960146.aspx

也见 http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.begingetresponse.aspx

把这件事搞好有点像噩梦。您需要创建回调来传递到每个“begin”方法,然后运行该方法的“continue”。(别忘了确保所有异常处理和完成的同步逻辑都是正确的!)当你在今天的C中写下这篇文章时,你的代码会变成一堆毫无希望的意大利面,但这是你实现目标的唯一方法(不让线程阻塞I/O等待)。

另一方面,如果这是你处境的原因, F# 使这非常简单和直接的作者正确。见 this video (也就是说,从52:20开始的8分钟)作为概要。

编辑

为了回答丹的评论,这里有一个非常粗略的草图…我从我在Outlook中写的一封电子邮件中提取了它,我怀疑它是编译的。异常路径总是粗糙的,所以要小心(如果抛出cb呢?);您可能希望在C_某处(我不知道在哪里,我确信一定有很多)找到一个可靠的ar/begin/end实现,并将其用作模型,但这显示了要点。问题是,一旦你写了这篇文章,你就会一直拥有它;beginrun和endrun在任何f异步对象上都作为“开始/结束”工作。我们在F bug数据库中有一个建议,在未来的F库版本中,在异步的基础上公开开始/结束APM,以便更容易地使用传统C代码的F异步计算。(当然,我们也在努力更好地使用.NET 4.0中并行任务库中的“task”。)

type AR<’a>(o,mre,result) =
    member x.Data = result
    interface IAsyncResult with
        member x.AsyncState = o
        member x.AsyncWaitHandle = mre
        member x.CompletedSynchronously = false
        member x.IsCompleted = mre.IsSignalled

let BeginRun(a : Async<’a>, cb : AsyncCallback, o : obj) =
    let mre = new ManualResetEvent(false)
    let result = ref None
    let iar = new AR(o,mre,result) :> IAsyncResult
    let a2 = async { 
        try
            let! r = a
            result := Choice2_1(r)
        with e ->
            result := Choice2_2(e)
            mre.Signal()
            if cb <> null then 
                cb.Invoke(iar)
            return () 
    }
    Async.Spawn(a2)
    iar

let EndRun<’a>(iar) =
    match iar with
    | :? AR<’a> as ar -> 
        iar.AsyncWaitHandle.WaitOne()
        match !(ar.Data) with
        | Choice2_1(r) -> r
        | Choice2_2(e) -> raise e

你可能会发现Jeff Richter的 AsyncEnumerator 简化了很多事情。你可以在电视上看到 PowerThreading 图书馆。

毫无疑问:使用 Concurrency and Coordination Runtime . 它使用了许多上面提到的技术,并将使您的代码比滚动自己的代码更简洁。