Thêm vào danh sách trong một vòng lặp Parallel.ForEach một cách threadsafe

Question

Tôi có một chút mã mà làm việc như thế này trên một danh sách các đối tượng obj gọi ListofObjects:

List<SomeObject> NewListofObjects<SomeObject>(); 

Parallel.ForEach(ListofObjects, obj => 

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

NewListofObjects.Add(newobj); 

); 

Bây giờ tôi ra khỏi Parallel .ForMỗi vòng lặp, và tôi muốn thực hiện một thao tác trên NewListofObjects. Tuy nhiên, tôi nhận được lỗi này khi tôi cố gắng: "Đã cố gắng đọc hoặc ghi bộ nhớ được bảo vệ. Đây thường là dấu hiệu cho thấy bộ nhớ khác bị hỏng".

Đây có phải là vì phương pháp NewListofObjects.Add (newobj) của tôi không phải là luồng an toàn không? Nếu vậy, làm thế nào tôi có thể làm cho nó threadsafe?

Answer 1

Đây có phải vì phương pháp NewListofObjects.Add(newobj) của tôi không phải là chủ đề an toàn không?

Đúng. Nó không phải là chủ đề an toàn.

Bất kỳ thành viên nào không được đảm bảo an toàn chỉ.

Đó là từ MSDN tham chiếu đến List<T> (cuộn đến phần có tiêu đề "An toàn chủ đề").

Nếu có, làm thế nào tôi có thể làm cho chủ đề an toàn hơn?

Sử dụng bộ sưu tập đồng thời, như ConcurrentBag<T>. Lưu ý rằng bạn mất khả năng theo dõi thứ tự các mục đã được chèn vào.

Answer 2

Bạn có thể sử dụng khối locking như mã sau để chèn các mục vào danh sách của mình theo cách an toàn.

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... 
    });