Parallel.ForEach với việc thêm vào danh sách

Question

Tôi đang cố chạy nhiều chức năng kết nối với một trang web từ xa (theo mạng) và trả về một danh sách chung. Nhưng tôi muốn chạy chúng cùng một lúc.

Ví dụ:

public static List<SearchResult> Search(string title) 
{ 
    //Initialize a new temp list to hold all search results 
    List<SearchResult> results = new List<SearchResult>(); 

    //Loop all providers simultaneously 
    Parallel.ForEach(Providers, currentProvider => 
    { 
     List<SearchResult> tmpResults = currentProvider.SearchTitle((title)); 

     //Add results from current provider 
     results.AddRange(tmpResults); 
    }); 

    //Return all combined results 
    return results; 
} 

Như tôi đã nhìn thấy nó, chọc kim nhiều lần để 'kết quả' có thể happend cùng lúc ... Mà có thể sụp đổ ứng dụng của tôi.

Làm cách nào để tránh điều này?

Answer 1

//In the class scope: 
Object lockMe = new Object();  

//In the function 
lock (lockMe) 
{  
    results.AddRange(tmpResults); 
} 

Về cơ bản, khóa có nghĩa là chỉ có một luồng có thể truy cập vào phần quan trọng đó cùng một lúc.

Answer 2

Bộ sưu tập đồng thời mới cho .Net 4; chúng được thiết kế để hoạt động với chức năng song song mới.

Xem Concurrent Collections in the .NET Framework 4:

Trước NET 4, bạn phải cung cấp cơ chế đồng bộ hóa của riêng bạn nếu nhiều luồng có thể truy cập vào một bộ sưu tập được chia sẻ duy nhất. Bạn phải khóa bộ sưu tập ...

... các lớp và giao diện [mới] trong System.Collections.Concurrent [được thêm trong .NET 4] cung cấp triển khai nhất quán cho [...] lập trình đa luồng các vấn đề liên quan đến dữ liệu được chia sẻ qua các luồng.

Answer 3

Bạn có thể sử dụng concurrent collection.

Các namespace System.Collections.Concurrent cung cấp một số các lớp học tập thread-safe nên được sử dụng ở vị trí của loại tương ứng trong System.Collections và System.Collections.Generic namespace bất cứ khi nào nhiều luồng đang truy cập vào bộ sưu tập đồng thời.

Bạn có thể sử dụng ví dụ ConcurrentBag vì bạn không đảm bảo thứ tự các mục sẽ được thêm vào.

Trình bày một bộ sưu tập các đối tượng an toàn, không có thứ tự.

Answer 4

Điều này có thể được diễn tả ngắn gọn bằng PLINQ của AsParallel và SelectMany:

public static List<SearchResult> Search(string title) 
{ 
    return Providers.AsParallel() 
        .SelectMany(p => p.SearchTitle(title)) 
        .ToList(); 
} 

Answer 5

Đối với những người thích mã:

public static ConcurrentBag<SearchResult> Search(string title) 
{ 
    var results = new ConcurrentBag<SearchResult>(); 
    Parallel.ForEach(Providers, currentProvider => 
    { 
     results.Add(currentProvider.SearchTitle((title))); 
    }); 

    return results; 
}