1

我通过回调内部的 websocket 发送几条消息。问题是，如果一个发送未完成而另一个发送启动，则功能超出异常。由于socket.SendAsync()是异步的，我可以用await. 一旦我使用，await我将不得不将我的 lambda 表达式声明为async. 但是一旦我这样做，就永远不会调用回调。有谁知道为什么或对此有解决方案/解决方法？

示例代码：

queue.QueueCompleted += async (s, eA) =>
    {
        z = dr.Start + 1;
        while (z < (dr.Start + 1 + dr.Limit))
        {
            string path = AppDomain.CurrentDomain.BaseDirectory + @"DCM\" + dr.Code.Replace('.', '_') + @"\IMAGE" + z.ToString() + ".jpg";
            Image image = null;
            image = Image.FromFile(path);
            ImageConverter ic = new ImageConverter();
            byte[] buffer = (byte[])ic.ConvertTo(image, typeof(byte[]));
            try
            {
                if (socket != null && socket.State == WebSocketState.Open)
                {
                    Debug.WriteLine("REACHED");
                    await socket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Binary, true, CancellationToken.None);
                    image.Dispose();
                }
            }
            catch (Exception e)
            {
                image.Dispose();
                break;
            }
            z++;
        }
    };

回调很简单EventHandler，被称为if(QueueCompleted != null) QueueCompleted(e, null);

4

2 回答 2

2

可能不是最有效的，但这是我用于内联异步代码的模式：

queue.QueueCompleted += (s, eA) =>
            {
                Task.Run(async ()=>{
                    //blah
                });
            };
于 2012-09-20T18:17:25.440 回答
2

你可以试试

queue.QueueCompleted += (a, b) => { Task.Run(async ()=> { ....   });  };

链接：http: //msdn.microsoft.com/en-us/library/hh195051.aspx

于 2012-09-20T18:18:13.723 回答