trả về null với PLINQ

Question

tôi có một phương pháp mở rộng cho IEnumerable, sau đó lặp lại thông qua bộ sưu tập, thực hiện công việc kinh doanh của mình và sau đó trả về một IEnumerable mới.

Tôi đã cố gắng sử dụng PLINQ sử dụng .AsParallel(). ForAll() tăng tốc độ lặp lại đáng kể là null.

Tôi cho rằng điều này có thể là do nó trả lại bộ sưu tập trước khi tất cả 'doanh nghiệp' có cơ hội hoàn thành? nếu tôi gỡ lỗi và đặt trong một breakpoint, không có null.

có loại phương pháp 'chờ cho hoạt động này được hoàn thành' mà tôi nên sử dụng không?

CHỈNH SỬA: để rõ ràng hơn một chút, có logic nghiệp vụ trong forall, sửa đổi thuộc tính, v.v. cần phải có một hành động lặp, thay vì chỉ đơn giản là chọn một cái gì đó.

Answer 1

Câu trả lời tùy thuộc vào ý của bạn là trả về, vì phương thức ForAll không trả lại bất kỳ điều gì. Nó gọi đại biểu bạn chỉ định song song cho tất cả các phần tử của bộ sưu tập. Tôi sẽ giả sử rằng mã của bạn trông như thế này:

data.AsParallel().ForAll(() => /* calculate and store result somewhere */); 
// more code 

Phương pháp ForAll không chờ đợi cho tất cả các đại biểu để hoàn thành, vì vậy more code có thể thực hiện trước khi tất cả các đại biểu đầy đủ (và bạn cũng cần phải cẩn thận trong store result somewhere ! chút, bởi vì nó có thể chạy đồng thời cho nhiều đại biểu)

tôi nghĩ rằng các mã có thể được viết lại thanh lịch hơn bằng cách sử dụng phương pháp Select:

var res = data.AsParallel().Select(() => /* calculate the result */); 

Trong cas này e, đại biểu chỉ trả về kết quả. Phương thức Where thu thập tất cả các kết quả và khi bạn lặp lại trên trả về IEnumerable, nó đảm bảo rằng tất cả các đại biểu đã hoàn thành việc tính toán.

Answer 2

ForAll() không thực hiện hợp nhất và trả về ngay lập tức. Parallel.ForEach() có lẽ là chức năng bạn đang tìm kiếm.

tức là thay vì:

collection.AsParallel().ForAll(t=>t.doWork());

cái gì đó như

Parallel.ForEach(collection.AsParallel(), t=>t.doWork());