Jar*_*rda 3 c# arrays concurrency lambda
任何人都可以告诉我,这段代码怎么可能:
for (byte i = 0; i < someArray.Length; i++)
{
pool.QueueTask(() =>
{
if (i > 0 && i < someArray.Length)
{
myFunction(i, someArray[i], ID);
}
});
}
Run Code Online (Sandbox Code Playgroud)
落在myFunction调用的行上,IndexOutOfRangeException因为i变量的值等于someArray.Length?我真的不明白......
注意:pool是具有2个线程的简单线程池的实例.
注2:bytefor循环中的类型是故意放置的,因为数组长度不能超过字节最大值(根据前面创建数组的逻辑),我需要变量i为类型byte.
你的代码正在创建一个闭包i,someArray.Length每次执行时它都会结束.在Action你最终突入QueueTask()保留的for循环的状态,并使用的值i在执行时间.这是一个表达同样问题的可编译代码示例,
static void Main(string[] args)
{
var someArray = new[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
var fns = new List<Action>();
for (int i = 0; i < someArray.Length; i++)
{
fns.Add(() => myFunction(i, someArray[i]));
}
foreach (var fn in fns) fn();
}
private static void myFunction(int i, int v)
{
Console.WriteLine($"{v} at idx:{i}");
}
Run Code Online (Sandbox Code Playgroud)
你可以通过复制本地的闭合变量来解决这个问题,该变量保留了i创建时的值Action.
static void Main(string[] args)
{
var someArray = new[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
var fns = new List<Action>();
for (int i = 0; i < someArray.Length; i++)
{
var local = i;
fns.Add(() => myFunction(local, someArray[local]));
}
foreach (var fn in fns) fn();
}
private static void myFunction(int i, int v)
{
Console.WriteLine($"{v} at idx:{i}");
}
Run Code Online (Sandbox Code Playgroud)
相关阅读:http://csharpindepth.com/Articles/Chapter5/Closures.aspx
| 归档时间: |
|
| 查看次数: |
95 次 |
| 最近记录: |