时间：2019-03-17 标签：c#foreachwithAction.BeginInvoke

Question

好吧，我这里有一个问题。 这是循环。

lock (ClientLocker)
{
    Trace.WriteLine("#WriteAll: " + sm.Header);
    foreach (Client c in Clients)
    {
        if (c.LoggedIn)
        {
            Trace.WriteLine("#TryWriteTo[" + c.Id + "](" + sm.Header + ")");
            LazyAsync.Invoke(() => c.WriteMessage(sm));
        }
    }
}

这是 LazyAsync

public static class LazyAsync
{
    public static void Invoke(Action a)
    {
        a.BeginInvoke(a.EndInvoke, null);
    }
}

每个 Client 都包含一个 socket，所以我几乎无法克隆它。 问题是，当我对 c.WriteMessage 执行 Invoke 时，由于执行被延迟，它通常不会在列表中的第一对上触发，并且会有时实际上只在最后一个项目上发射一大堆。

我知道这与 c 作为引用在 Invoke 实际被调用之前发生变化有关，但有没有办法避免这种情况？

执行一般的 for(int i=0 etc 循环似乎无法解决此问题。

有人知道如何解决此问题吗？

记住，不能克隆 客户端。

Answer 1

将您的 c 复制到本地变量，如下所示：

lock (ClientLocker)
{
    Trace.WriteLine("#WriteAll: " + sm.Header);
    foreach (Client c in Clients)
    {
        if (c.LoggedIn)
        {
            Client localC = c;
            Trace.WriteLine("#TryWriteTo[" + c.Id + "](" + sm.Header + ")");
            LazyAsync.Invoke(() => localC.WriteMessage(sm));
        }
    }
}

如果您想获取更多信息，请在网络上搜索：“访问修改后的闭包”。

Answer 2

您的怀疑是正确的：变量 c 被 lambda 表达式捕获，但直到稍后才进行评估。

每当您在 lambda 表达式中使用循环变量时，就会弹出这种错误，因为循环变量的作用域是在循环之外，而不是在循环的每次迭代中。

您可以通过在 foreach 循环中创建一个新的局部变量，为其分配 c，然后将该新的局部变量传递到 lambda 表达式来解决此问题

lock (ClientLocker)
{
    Trace.WriteLine("#WriteAll: " + sm.Header);
    foreach (Client c in Clients)
    {
        if (c.LoggedIn)
        {
            Trace.WriteLine("#TryWriteTo[" + c.Id + "](" + sm.Header + ")");

            Client copyOfC = c;
            LazyAsync.Invoke(() => copyOfC.WriteMessage(sm));
        }
    }
}

：一些相关的 StackOverflow 帖子：

• 访问修改后的闭包
• 有原因吗C# 在 foreach 中重用变量？
• C# lambda，当你认为局部变量值没有被采取？

Answer 3

尝试将 c 设置为局部变量并对其调用 LazyAsync.Invoke，以避免 c 被 foreach 在调用发生之前循环。当LazyAsync.Invoke执行c.WriteMessage时，它会在c现在指向的任何内容上调用WriteMessage，而不是评估 LazyAsync.Invoke(() => c.WriteMessage(sm)) 时的情况

foreach (Client c in Clients)
{
    if (c.LoggedIn)
    {
        Trace.WriteLine("#TryWriteTo[" + c.Id + "](" + sm.Header + ")");

        Client client = c;
        LazyAsync.Invoke(() => client.WriteMessage(sm));
    }
}