Tại sao Parallel.ForEach không chạy nhiều luồng?

Question

Hôm nay tôi đã thử thực hiện một số tối ưu hóa cho câu lệnh foreach, hoạt động trên XDocument.

Trước khi tối ưu hóa:

foreach (XElement elem in xDoc.Descendants("APSEvent").ToList()) 
{ 
    //some operations 
} 

Sau khi tối ưu hóa:

Parallel.ForEach(xDoc.Descendants("APSEvent").ToList(), elem => 
{ 
    //same operations 
}); 

tôi thấy rằng NET trong Parallel.ForEach(...) mở CHỈ một thread! Kết quả là khoảng thời gian của Parallel lớn hơn tiêu chuẩn foreach.

Tại sao bạn nghĩ .NET chỉ mở 1 chuỗi? Bởi vì khóa tập tin? Cảm ơn

Answer 1

Đó là do thiết kế mà Parallel.ForEach có thể sử dụng bài ít hơn yêu cầu để đạt được hiệu suất tốt hơn. Theo MSDN [link]:

Theo mặc định, các phương thức Parallel.ForEach và Parallel.For có thể sử dụng một số tác vụ khác nhau. Đó là lý do tại sao, ví dụ, lớp ParallelOptions có một tài sản MaxDegreeOfParallelism thay vì một thuộc tính "MinDegreeOfParallelism". Ý tưởng là hệ thống có thể sử dụng ít chuỗi hơn yêu cầu để xử lý vòng lặp.

Nhóm chủ đề .NET điều chỉnh động để thay đổi khối lượng công việc bằng cách cho phép số lượng chuỗi công việc cho các tác vụ song song thay đổi theo thời gian. Vào thời gian chạy, hệ thống quan sát xem việc tăng số lượng các luồng có cải thiện hay làm suy giảm toàn bộ thông lượng và điều chỉnh số lượng các chuỗi công việc cho phù hợp hay không.

Answer 2

Không phải lúc nào con đường song song là nhanh hơn so với "cách thời trang cũ" http://social.msdn.microsoft.com/Forums/en-US/parallelextensions/thread/c860cf3f-f7a6-46b5-8a07-ca2f413258dd

Answer 3

Có chính xác, Document.Load(...)locks the file và do nguồn lực tranh chấp giữa các chủ đề, TPL là không thể sử dụng sức mạnh của nhiều chủ đề. Hãy thử tải XML thành Stream và sau đó sử dụng Parallel.For(...).

Answer 4

Bạn có muốn có một bộ xử lý không? TPL có thể giới hạn số lượng chủ đề thành một trong trường hợp này. Điều tương tự có thể xảy ra nếu bộ sưu tập rất nhỏ. Hãy thử một bộ sưu tập lớn hơn. Xem this answer để biết thêm chi tiết về cách xác định mức độ song song.

Answer 5

sử dụng nó như thế này:

int ParallelThreads = 10; 
Parallel.ForEach(xDoc.Descendants("APSEvent").ToList(), new ParallelOptions() { MaxDegreeOfParallelism = ParallelThreads }, (myXDOC, i, j) => 
{ 
//do whatever you want here 
}); 

Answer 6

Từ mô tả sự cố, không có gì giải thích tại sao TPL không sinh ra nhiều chuỗi hơn.

Không có bằng chứng nào trong câu hỏi thậm chí là vấn đề. Điều đó có thể được sửa chữa khá dễ dàng: bạn có thể đăng nhập id thread, trước khi bạn nhập vòng lặp, và như là điều đầu tiên bạn làm bên trong vòng lặp của bạn.

Nếu nó luôn luôn là cùng một số, đó là TPL không sinh ra chủ đề. Sau đó, bạn nên thử các phiên bản khác nhau của mã của mình và những thay đổi nào kích hoạt TPL để tuần tự hóa mọi thứ. Một lý do có thể là nếu có một số lượng nhỏ các yếu tố trong danh sách của bạn.TPL phân vùng bộ sưu tập của bạn và nếu bạn chỉ có một vài mục, bạn có thể kết thúc chỉ với một lô. Hành vi này được cấu hình bằng cách này.

Có thể bạn đang vô ý lấy khóa trong vòng lặp, sau đó bạn sẽ thấy nhiều số khác nhau, nhưng không có tăng tốc. Sau đó, đơn giản hóa mã cho đến khi vấn đề biến mất.