ThreadPool Exception

本文关键字：Exception ThreadPool | 更新日期: 2023-09-27 18:18:31

我需要一次使用60个线程(并行)，为此我使用ThreadPool。这里有一个例外:

temp = 1;
for (int j = 0; j < temp; j++) {
   ThreadPool.QueueUserWorkItem(delegate(object notUsed) {
      RequestToRajons(rajs_ip[j].ToString(),rajs_name[j].ToString(), sql_str, base_str, saveFileDialog1,j); 
   });
}

这给了我一个例外，j=1(数组超出范围)。但我有一个条件!如果我在step中使用断点，就不会出现异常。

ThreadPool Exception

这是典型的/capture问题，因为您正在"捕获"j，而只有一个j 。所有线程都使用相同的j变量进行处理;它们看到的值是不确定的，但是最后几个线程很可能会看到循环的退出值，即多了一个。

: 

for (int loopIndex = 0; loopIndex < temp; loopIndex++)
{
    int j = loopIndex;
    // the following line has not changed at all
    ThreadPool.QueueUserWorkItem(delegate(object notUsed) { RequestToRajons(rajs_ip[j].ToString(),rajs_name[j].ToString(), sql_str, base_str, saveFileDialog1,j); });
}

听起来很傻，但是您现在有了一个j per循环迭代，因为捕获的范围取决于变量的声明范围。这里，j是在循环中定义的。在for循环中，变量在技术上是在循环之外定义的。

另一种方法是对线程池使用参数: 
for(int loopIndex = 0; loopIndex < temp; loopIndex++)
{
    ThreadPool.QueueUserWorkItem(delegate(object ctx) {
        int j = (int) ctx;
        // stuff involving j
    }, loopIndex); // <=== see we're passing it in, rather than capturing
}

这是"捕获变量"和匿名方法如何工作的扩展版本，过度简化的版本;首先，编译器会为你做这些:

class CaptureContext { // <== the real name is gibberish
    public int j; // yes it is a field; has to be, so `ref` and `struct` etc work
    public void SomeMethod(object notUsed) {
        RequestToRajons(rajs_ip[j].ToString(),rajs_name[j].ToString(), sql_str, base_str, saveFileDialog1,j); 
    }
    // it might also be capturing "this"; I can't tell from your example
}

，你的方法变成(因为j技术上是在循环外定义的):

var ctx = new CaptureContext();
for (ctx.j = 0; ctx.j < temp; ctx.j++) {
    ThreadPool.QueueUserWorkItem(ctx.SomeMethod);
}

;你能看到只有一个"捕获"对象，并且我们在ctx.j不一定是我们认为的时候随机使用它吗?修复程序将其重写为:

for (int loopIndex = 0; loopIndex < temp; loopIndex++) {
    var ctx = new CaptureContext();
    ctx.j = loopIndex;
    ThreadPool.QueueUserWorkItem(ctx.SomeMethod);
}

在这里，你可以看到有一个"捕获"对象每个迭代，这是因为j是在循环内声明的 ?"什么是新的捕获上下文"取决于被捕获变量的范围。

相关文章：