lambda 表达式的异常

Question

奇怪的是，我仍然不明白，是这样的：

说，

try
{
    stateClient.Socket.BeginSend(messagePrefixed, 0, messagePrefixed.Length,
        SocketFlags.None, ar => stateClient.Socket.EndSend(ar), stateClient);
}
catch (SocketException ex)
{
    // Handle SocketException.
}
catch (ObjectDisposedException ex)
{
    // Handle ObjectDisposedException.
}

我不明白为什么返回 ObjectDisposeException 的 lambda 表达式没有被捕获！？我正在深入研究 lambda，但我无法理解它。与 lambda 的范围有关吗？范围变量？线程问题？我知道 lambda 本质上没有多线程，但正如您所看到的，返回来自 BeginSend 创建的另一个线程。在将实现转换为 lambda 之前，当我有一个处理 EndSend 的 AsyncCallBack 方法时，这是可以的。

任何帮助表示赞赏。 先感谢您。

Answer 1

您是对的，lamda 没有固有的异步性或多线程内置功能，但 Socket.BeginSend 具有。

所发生的情况是，try 块封装了对 BeginSend 的调用。如果该调用成功，则不会引发异常并且封闭方法返回，无论其他线程上发生什么情况。

如果在调用 BeginSend 期间发生异常，您的 catch 块将被调用。

但是，lambda 表达式是异步回调，因此稍后才会调用它。这发生在单独线程上的单独调用堆栈中，因此 try 块在那里不起作用。

如果您希望对回调进行错误处理，则需要在回调本身内部（即 lambda 内部）指定它。

Answer 2

它与 lambda 无关。 BeginSend 调用的委托在另一个线程上执行，因此异常不会在具有 catch 语句的线程上引发，因此未处理。将异常处理与 EndSend 代码一起放置。

有关详细信息，请参阅 http://msdn.microsoft.com/en-us/库/38dxf7kt.aspx

Answer 3

对 lambda 定义的匿名函数的调用是异步发生的。到那时，try 块将早已消失。

您的代码与：-

AsyncCallBack cb = delegate(AsyncCallback ar) { stateClient.Socket.EndSend(ar); }
stateClient.Socket.BeginSend(messagePrefixed, 0, messagePrefixed.Length,
   SocketFlags.None, cb, stateClient);

现在您可以定义一个函数：-

void MyCallBack(AsyncCallback ar) { stateClient.Socket.EndSend(ar); }

然后上面的代码可以变成：-

stateClient.Socket.BeginSend(messagePrefixed, 0, messagePrefixed.Length,
   SocketFlags.None, MyCallBack, stateClient);

在这种情况下，它几乎都是相同的事情。要点是 Try 捕获在其主体名义执行期间发生的异常。事实上，您在主体内以 lambda 形式定义的代码并不会使该代码像上面的 MyCallBack 那样更多地受到 Try 块的约束。两者都将在包含 Try 块的函数之后运行，或者可能在不同的线程上运行。

Answer 4

正如其他答案中已经指出的那样，对 lambda 的调用将异步发生，这就是异常未被捕获的原因。

异步调用从文件读取的示例：

File.WriteAllText("example.txt", new string('0', 2048));

Stream s = File.OpenRead("example.txt");

var buffer = new byte[1024];

Console.WriteLine(
    "Thread: {0} - Before asynch call...", 
    Thread.CurrentThread.ManagedThreadId);

s.BeginRead(
    buffer, 
    0, 
    1024, 
    ar =>
    {
        Thread.Sleep(100); // Simulate a long op
        Console.WriteLine(
            "Thread: {0} - Callback called...", 
            Thread.CurrentThread.ManagedThreadId);
    }
    , 0);

Console.WriteLine(
    "Thread: {0} - After asynch call...",
    Thread.CurrentThread.ManagedThreadId);

// Wait for callback to be executed
Thread.Sleep(2000);

输出为：

Thread: 1 - Before asynch call...
Thread: 1 - After asynch call...
Thread: 3 - Callback called...

Answer 5

尽管我认为到目前为止我是对的，但 BeginSend 永远不会返回异常，所有例外和结果都会在 EndSend() 方法上重新出现，因此我可以移动我的 try catch 块。