1

我来自Threading with Parallel.For 添加列表。对于链接中的示例,两个线程用于调用Parallel.Invoke仍然很慢,所以我想在循环内执行一些多线程,假设我不关心添加的订单项。但是parallel.for没有像预期的那样工作,并给出了 indexoutofRange 异常。有人请帮忙吗?

private static void Main(string[] args)
{
    var dict1 = new Dictionary<int, string>();
    var dict2 = new Dictionary<int, string>();
    Stopwatch s = Stopwatch.StartNew();
    Parallel.Invoke(() => FillDictionary(dict1, 10000000), () => FillDictionary(dict2, 10000000));
    //FillDictionary(dict1, 10000000);
    //FillDictionary(dict2, 10000000);
    Console.WriteLine("test");
    Console.WriteLine(s.Elapsed.TotalMilliseconds);
    Console.ReadLine();
}
private static void FillDictionary(Dictionary<int, string> toFill, int itemCount)
{
    //for (int i = 0; i < itemCount; i++)
        //toFill.Add(i, "test" + i);
    Parallel.For(0, itemCount, (i) => toFill.Add(i, "test" + i));    
}
4

1 回答 1

4

Dictionary不是线程安全的。改为ConcurrentDictionary<TKey, TValue>使用。

于 2014-09-21T18:22:29.590 回答