Parallel.ForEach trong khi giữ lại đơn hàng

Question

Tôi có List<byte[]> và tôi muốn deserialize từng byte[] thành Foo. Danh sách được sắp xếp và tôi muốn viết một vòng lặp song song trong đó kết quả List<Foo> chứa tất cả Foo theo thứ tự giống với số byte[] gốc. Danh sách là lớn đáng kể để làm cho hoạt động song song đáng giá. Có cách tích hợp để thực hiện việc này không?

Nếu không, bất kỳ ý tưởng nào để đạt được tốc độ vượt qua tất cả hoạt động này một cách đồng bộ?

Cảm ơn

Answer 1

Từ thông tin bạn' đã đưa ra, tôi hiểu bạn muốn có một mảng đầu ra của Foo với kích thước bằng với mảng đầu vào của byte? Điều này có đúng không?

Nếu vậy, có thao tác rất đơn giản. Đừng bận tâm với việc khóa hoặc đồng bộ các cấu trúc, chúng sẽ làm xói mòn tất cả tốc độ mà sự song song đó mang lại cho bạn.

Thay vào đó, nếu bạn tuân theo quy tắc đơn giản này bất kỳ thuật toán có thể được song song mà không cần khóa hoặc đồng bộ hóa:

Đối với mỗi yếu tố đầu vào X [i] xử lý, bạn có thể đọc từ bất kỳ yếu tố đầu vào X [j], nhưng chỉ viết thư cho yếu tố đầu ra Y [i]

Tra cứu Scatter/Thu thập, loại hình này hoạt động được gọi là một tập hợp như chỉ có một yếu tố đầu ra được ghi vào.

Nếu bạn có thể sử dụng nguyên tắc trên thì bạn muốn tạo mảng đầu ra Foo [] lên phía trước và sử dụng Parallel.For không ForEach trên mảng đầu vào.

Ví dụ:

 List<byte[]> inputArray = new List<byte[]>(); 
     int[] outputArray = new int[inputArray.Count]; 

     var waitHandle = new ManualResetEvent(false); 
     int counter = 0; 

     Parallel.For(0, inputArray.Count, index => 
      { 
       // Pass index to for loop, do long running operation 
       // on input items 
       // writing to only a single output item 
       outputArray[index] = DoOperation(inputArray[index]); 

       if(Interlocked.Increment(ref counter) == inputArray.Count -1) 
       { 
        waitHandle.Set(); 
       } 
      }); 

     waitHandler.WaitOne(); 

     // Optional conversion back to list if you wanted this 
     var outputList = outputArray.ToList(); 

Answer 2

Bạn có thể sử dụng một từ điển threadsafe với một phím chỉ số int để lưu trữ các reult từ foo nên cuối cùng bạn sẽ có tất cả những người đặt hàng dữ liệu trong từ điển