Làm thế nào để quản lý lưu trữ cục bộ luồng (TLS) khi sử dụng TPL?

Question

Tôi muốn lưu trữ thông tin ngữ cảnh ghi nhật ký trong TLS để tôi có thể đặt giá trị tại điểm nhập và có giá trị đó trong tất cả các ngăn xếp kết quả. Điều này làm việc tốt, nhưng tôi cũng sử dụng TPL và ThreadPool. Vấn đề sau đó sẽ trở thành cách di chuyển dữ liệu TLS đến các chủ đề khác. Tôi có thể làm tất cả bản thân mình, nhưng sau đó tôi mất phương pháp tốt đẹp như Parallel.For.

Có cách nào để sao chép TLS khi sử dụng TPL không? Điều này cũng sẽ áp dụng cho C# khi nó có tính năng chờ.

Cảm ơn, Erick

Answer 1

Thông thường, điều này được thực hiện thông qua việc sử dụng một quá tải của Parallel.For rằng đã cung cấp cho các dữ liệu chủ đề của địa phương.

Quá tải này cho phép bạn cung cấp khởi tạo và đại biểu cuối cùng, có hiệu quả trở thành khởi tạo cho mỗi luồng cho dữ liệu cục bộ luồng của bạn và chức năng giảm ở cuối để "hợp nhất" kết quả với nhau (được chạy một lần cho mỗi thread). I wrote about this in detail here.

Các hình thức cơ bản là để làm một cái gì đó như:

object sync = new object(); 
double result = 0; 

Parallel.For(0, collection.Count, 
    // Initialize thread local data: 
    () => new MyThreadSpecificData(), 
    // Process each item 
    (i, pls, currentThreadLocalData) => 
    { 
     // Generate a NEW version of your local state data 
     MyThreadSpecificData newResults = ProcessItem(collection, i, currentThreadLocalData); 
     return newResults; 
    }, 
    // Aggregate results 
    threadLocalData => 
    { 
     // This requires synchronization, as it happens once per thread, 
     // but potentially simultaneously 
     lock(sync) 
      result += threadLocalData.Results; 
    }); 

Answer 2

tôi tìm thấy một giải pháp cho vấn đề mà không yêu cầu mã. Tôi đã có thể sử dụng CallContext để đính kèm dữ liệu vào một "chuỗi logic". Dữ liệu này được chuyển từ chuỗi bắt đầu đến các luồng được tạo bởi TPL cũng như ThreadPool.

http://www.wintellect.com/CS/blogs/jeffreyr/archive/2010/09/27/logical-call-context-flowing-data-across-threads-appdomains-and-processes.aspx

Answer 3

Có, tất nhiên, nhưng thay thế khác: Viết một lớp TaskLocal (T), như chúng ta đã làm, mà căn cứ lưu trữ trên Task hiện tại, chứ không phải là chủ đề hiện hành. Thành thật mà nói, tôi không có ý tưởng tại sao Microsoft đã không làm điều này như là một phần của việc thực hiện Nhiệm vụ ban đầu của họ.

Lưu ý thực hiện quan trọng: Vì mã tác vụ chờ cuộc gọi có thể được chia nhỏ và tiếp tục là khác nhau TaskId, bạn cũng cần làm những gì chúng tôi đã làm và triển khai phương pháp trong TaskLocal (T) cho những người trước đó, sau đó lưu TaskId ban đầu ở đầu Nhiệm vụ và ánh xạ nó sau mỗi cuộc gọi đang chờ.