14

我有一些代码在名为 ListofObjects 的 obj 对象列表上像这样工作：

List<SomeObject> NewListofObjects<SomeObject>();

Parallel.ForEach(ListofObjects, obj =>

//Do some operations here on obj to get a newobj

NewListofObjects.Add(newobj);

);

现在我退出了 Parallel.ForEach 循环，我想对 NewListofObjects 进行操作。但是，当我尝试执行以下操作时出现此错误：“尝试读取或写入受保护的内存。这通常表明其他内存已损坏”。

这是因为我的 NewListofObjects.Add(newobj) 方法不是线程安全的吗？如果是这样，我怎样才能使它成为线程安全的？

4

3 回答 3

29

这是因为我的NewListofObjects.Add(newobj)方法不是线程安全的吗？

正确的。它不是线程安全的。

不保证任何实例成员都是线程安全的。

这是来自MSDN的参考List<T>（滚动到标题为“线程安全”的部分）。

如果是这样，我怎样才能使它成为线程安全的？

使用并发集合，例如ConcurrentBag<T>. 请注意，您将无法跟踪项目插入的顺序。

于 2013-07-02T02:16:54.803 回答
17

您可以使用locking类似于以下代码的块以线程安全的方式将项目插入列表中。

var sync = new object();
var myNewList = new List<SomeObject>();
Parallel.ForEach(myListOfSomethings, a =>
    {
        // Some other code...
        var someObj = new SomeObject();
        // More other code...
        lock(sync)
        {
            myNewList.Add(someObj);
        }
        // Even more code...
    });
于 2013-07-02T03:07:55.860 回答
1

.NET Framework 4 引入了 System.Collections.Concurrent 命名空间，其中包括多个线程安全和可伸缩的集合类。 https://docs.microsoft.com/en-us/dotnet/standard/collections/thread-safe/

BlockingCollection<int>[] sourceArrays = new BlockingCollection<int>[5];
for (int i = 0; i < sourceArrays.Length; i++)
    sourceArrays[i] = new BlockingCollection<int>(500);
Parallel.For(0, sourceArrays.Length * 500, (j) =>
{
    int k = BlockingCollection<int>.TryAddToAny(sourceArrays, j);
    if (k >= 0)
        Console.WriteLine("added {0} to source data", j);
});
于 2019-03-27T20:03:18.030 回答