有没有办法使用TPL对枚举对象（IDataReader）执行并行操作？

Question

我有我目前使用它与

int count=0; 
string key= string.Empty 
string prv_Key = string.Empty 
while(source.MoveNext()) 
{ 
    count++; 
    key = source["ItemId"] 
    --- 
    ---- Some logic --- 
    prv_Key = key; 
} 

我可以这样上面的代码转换为TPL与线程安全的一个枚举对象？
注：我不具备行数计数源对象

Answer 1

你的代码显示有范围的IEnumerator<T>，但是让我们假设你也有一个用于创建枚举的IEnumerable<T>。

您可以使用Parallel.ForEach并行化循环，并使用Interlocked.Increment以原子方式递增count。

另外，从你所看到的，似乎没有理由在循环外声明两个字符串。除非你需要跨线程共享这些变量，否则不要。

int count = 0; 

Parallel.ForEach(items, i => { 

    int newCount = Interlocked.Increment(ref count); 

    string key = source["ItemId"] 
    string prv_Key = string.Empty; 
});