.NET ArrayList 并行处理

Question

我第一次尝试嵌入多线程并遇到一些意想不到的问题，希望你能提供帮助。

这是给我带来麻烦的代码片段：

ArrayList recordsCollection = new ArrayList();
ArrayList batchCollection = null;
int idx = 0;

while(true)
{
  // Some code to generate and assign new batchCollection here
  recordsCollection.Add(batchCollection);

  ThreadPool.QueueUserWorkItem(delegate
  {
    ProcessCollection(recordsCollection.GetRange(idx, 1));
  });
  Interlocked.Increment(ref idx);
}

private void ProcessCollection(ArrayList collection)
{
   // Do some work on collection here
}

调用 Process Collection 方法并且我尝试迭代集合时，我收到“基础列表中的范围无效”。

提前致谢！

更新：伙计们，谢谢你们每一个人。通过采纳您的建议，我能够大大简化并使其发挥作用。

Answer 1

此处没有必要使用 Interlocked.Increment。您希望局部变量 idx 只能被一个线程看到，因此不需要锁定。

目前，您正在“关闭循环变量”，这意味着线程看到的是变量的最新值，而不是创建委托时的值。您希望其他线程接收此变量的副本。即使原始变量发生变化，这些副本也不会改变。

尝试将代码更改为：

int j = idx;
ThreadPool.QueueUserWorkItem(delegate
{
    ProcessCollection(recordsCollection.GetRange(j, 1));
});

相关问题：

• 匿名循环内的 C# 委托

相关文章：

• 关闭被认为有害的循环变量

Answer 2

你有几个问题。

• 就像马克指出的那样，您正在捕获一个循环变量，这真的会让事情变得混乱。
• 您在修改集合的同时读取它，而无需使用同步机制。

我假设您省略了获取 batchCollection 的代码，然后为了简洁起见定期从 recordsCollection 中删除它们，否则也会出现问题。

以下是修复方法。

ArrayList recordsCollection = new ArrayList();  
ArrayList batchCollection = null;  
int idx = 0;  

while(true)  
{  
  lock (recordsCollection) 
  {
    recordsCollection.Add(batchCollection);  
  }

  int capturedIndex = idx; // Used for proper capturing.

  ThreadPool.QueueUserWorkItem(delegate  
  {
    ArrayList range;
    lock (recordsCollection)
    {
      range = recordsCollection.GetRange(capturedIndex, 1);
    }
    ProcessCollection(range);  
  });  

  idx++;
}  

或者我的重构版本，据我所知，它做了完全相同的事情......

List<List<Record>> recordsCollection = new ArrayList();  
List<Record> batchCollection = null;  

while(true)  
{  
  recordsCollection.Add(batchCollection);

  List<List<Record>> range = new List<List<Record>>();
  range.Add(batchCollection);

  ThreadPool.QueueUserWorkItem(delegate  
  {
    ProcessCollection(range);  
  });      
}  

Answer 3

你在这里玩火。
您有一个开放的闭包，请参阅：http://en.wikipedia.org/wiki/Closure_ (computer_science)

另外，如果您只获取一项，为什么还要使用 getRange ？

使用通用列表也可能有所帮助。

    private void wee()
    {
        List<List<string>> recordsCollection = new List<List<string>>();

        //int idx = 0;

        while(true)
        {
            //scope the batchcollection here if you want to start a thread with an anonymous delegate
            List<string> batchCollection = null;
            // Some code to generate and assign new batchCollection here
            recordsCollection.Add(batchCollection);

              ThreadPool.QueueUserWorkItem(delegate
              {
                  ProcessCollection(batchCollection);
              });
              //Interlocked.Increment(ref idx);
        }
    }
    private void ProcessCollection(List<string> collection)
    {
        // Do some work on collection here
    }

如果我错了，请纠正我，但我认为您不再需要 idx 变量。

另外，不要忘记异常是由调用堆栈引发的： http://www .codeproject.com/KB/architecture/exceptionbestpractices.aspx

干杯！