MaxDegreeOfParallelism làm gì?

Question

Tôi đang sử dụng Parallel.ForEach và tôi đang làm một số cập nhật cơ sở dữ liệu, bây giờ mà không cần thiết lập MaxDegreeOfParallelism, một bộ xử lý lõi kép kết quả trong thời gian chờ máy khách sql, nơi khác quad core xử lý máy bằng cách nào đó không timeout.

Bây giờ tôi không thể kiểm soát loại lõi bộ xử lý có sẵn khi mã của tôi chạy, nhưng có một số cài đặt tôi có thể thay đổi với MaxDegreeOfParallelism có thể chạy ít hoạt động cùng một lúc hơn và không dẫn đến hết thời gian chờ không?

Tôi có thể tăng thời gian chờ nhưng không phải là giải pháp tốt, nếu trên CPU thấp hơn, tôi có thể xử lý ít hoạt động đồng thời hơn, điều đó sẽ giảm tải trên CPU.

Ok tôi đã đọc tất cả các bài đăng và MSDN khác, nhưng sẽ thiết lập MaxDegreeOfParallelism để giá trị thấp hơn làm cho máy lõi tứ của tôi bị ảnh hưởng?

Ví dụ, có anyway để làm điều gì đó như thế, nếu CPU có hai lõi, sau đó sử dụng 20, nếu CPU có bốn lõi sau đó 40?

Answer 1

Câu trả lời là nó là giới hạn trên cho toàn bộ hoạt động song song, không phân biệt số lượng lõi.

Vì vậy, ngay cả khi bạn không sử dụng CPU vì bạn đang chờ IO, hoặc khóa, không có tác vụ bổ sung nào sẽ chạy song song, chỉ tối đa mà bạn chỉ định.

Để tìm hiểu điều này, tôi đã viết đoạn mã thử nghiệm này. Có một khóa nhân tạo trong đó để kích thích TPL sử dụng nhiều chủ đề hơn. Điều tương tự cũng sẽ xảy ra khi mã của bạn đang chờ IO hoặc cơ sở dữ liệu.

class Program 
{ 
    static void Main(string[] args) 
    { 
     var locker = new Object(); 
     int count = 0; 
     Parallel.For 
      (0 
      , 1000 
      , new ParallelOptions { MaxDegreeOfParallelism = 2 } 
      , (i) => 
        { 
         Interlocked.Increment(ref count); 
         lock (locker) 
         { 
          Console.WriteLine("Number of active threads:" + count); 
          Thread.Sleep(10); 
         } 
         Interlocked.Decrement(ref count); 
        } 
      ); 
    } 
} 

Nếu tôi không chỉ định MaxDegreeOfParallelism, ghi nhật ký bảng điều khiển cho thấy tối đa 8 tác vụ đang chạy cùng một lúc. Như thế này:

Number of active threads:6 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:6 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 
Number of active threads:7 

Nó bắt đầu thấp hơn, tăng theo thời gian và cuối cùng nó cố gắng chạy 8 cùng một lúc.

Nếu tôi hạn chế nó đến một số giá trị tùy ý (ví dụ 2), tôi nhận được

Number of active threads:2 
Number of active threads:1 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 
Number of active threads:2 

Oh, và điều này là trên một máy quadcore.

Answer 2

nó đặt số chủ đề để chạy song song ...

Answer 3

Có vẻ như mã mà bạn đang chạy song song được deadlocking, điều đó có nghĩa rằng trừ khi bạn có thể tìm và sửa chữa các vấn đề mà gây ra rằng, bạn không nên song song nó chút nào.

Answer 4

Ví dụ, có cách nào để làm điều gì đó giống như, nếu CPU có hai lõi, sau đó sử dụng 20, nếu CPU có bốn lõi thì 40?

Bạn có thể làm điều này để làm song song phụ thuộc vào số lượng các lõi CPU:

var options = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount * 10 }; 
Parallel.ForEach(sourceCollection, options, sourceItem => 
{ 
    // do something 
}); 

Tuy nhiên, mới hơn CPU của xu hướng sử dụng Hyper-Threading để mô phỏng lõi thêm. Vì vậy, nếu bạn có bộ xử lý lõi tứ, thì Environment.ProcessorCount có thể sẽ báo cáo điều này là 8 lõi. Tôi đã tìm thấy rằng nếu bạn thiết lập song song để tính toán cho các lõi mô phỏng thì nó thực sự làm chậm các chủ đề khác như các luồng giao diện người dùng.

Vì vậy, mặc dù hoạt động sẽ kết thúc nhanh hơn một chút, một giao diện người dùng ứng dụng có thể gặp phải tình trạng trễ đáng kể trong thời gian này. Chia 'Environment.ProcessorCount' cho 2 dường như đạt được tốc độ xử lý giống nhau trong khi vẫn giữ CPU sẵn sàng cho các chủ đề giao diện người dùng.