Không Parallel.ForEach Block?

Question

Chức năng .net Parallel.ForEach có chặn chặn cuộc gọi không? Tôi đoán hành vi này là một trong những hành vi sau:

1. Có, nó chặn cho đến khi mục chậm nhất thực hiện trả về.
2. Không, nó không chặn và trả về kiểm soát ngay lập tức. Các mục để chạy song song được thực hiện trên các chủ đề nền.

Hoặc có thể có điều gì khác đang xảy ra, bất kỳ ai cũng biết chắc chắn?

Câu hỏi này đã đưa ra khi thực hiện điều này trong một lớp học khai thác gỗ:

public class MultipleLoggingService : LoggingServiceBase 
{ 
    private readonly List<LoggingServiceBase> loggingServices; 

    public MultipleLoggingService(List<LoggingServiceBase> loggingServices) 
    { 
     this.loggingServices = loggingServices; 
     LogLevelChanged += OnLogLevelChanged; 
    } 

    private void OnLogLevelChanged(object sender, LogLevelChangedArgs args) 
    { 
     loggingServices.ForEach(l => l.LogLevel = LogLevel); 
    } 

    public override LogMessageResponse LogMessage(LogMessageRequest request) 
    { 
     if (request.LogMessage) 
      Parallel.ForEach(loggingServices, l => l.LogMessage(request)); 

     return new LogMessageResponse{MessageLogged = request.LogMessage}; 
    } 
} 

Chú ý phương pháp LogMessage gọi một số dịch vụ khai thác gỗ khác. Tôi cần phần đó để trả về ngay lập tức, vì vậy nó không chặn chuỗi gọi.

---

Cập nhật: Dựa trên nhận xét của người khác (chúng tôi đã xác nhận hành vi là # 1). Vì vậy, tôi đã đưa ra lời khuyên để sử dụng thư viện Task và viết lại vòng lặp như sau:

  if (request.LogMessage) 
      foreach (var loggingService in loggingServices) 
       Task.Factory.StartNew(() => loggingService.LogMessage(request)); 

Answer 1

Số 1 là chính xác; Parallel.ForEach không trở lại cho đến khi vòng lặp hoàn tất. Nếu bạn không muốn hành vi đó, bạn chỉ có thể thực hiện vòng lặp của mình dưới dạng Task và chạy nó trên một chuỗi khác.

Answer 2

Re cập nhật của bạn, StartNew trong một foreach bình thường():

Điều này có thể không phải là tối ưu nhất cho bộ sưu tập lớn, và bạn không nhận được một điểm để xử lý các lỗi.

Việc ghi nhật ký Dịch vụ của bạn có thể không chứa hàng nghìn mục nhưng việc xử lý lỗi vẫn là một điểm.

xem xét:

Task.Factory.StartNew(() => 
{ 
    try 
    { 
     Parallel.ForEach(loggingServices, l => l.LogMessage(request)); 
    } 
    catch(SomeException ex) 
    { 
     // at least try to log it ... 
    } 
});