測量TPL中的並行度

Question

任務並行庫和TPL數據流允許指定最大並行度。這個價值是一個上限，而不是一個保證。事實上，TPL將根據包括系統資源在內的多個因素確定實際並行度，而不會超出程序員指定的最大值。

是否有一些機制來確定TPL在某個時間點對並行度的選擇？

我在問具體問題，因爲我移植了一些相當複雜的代碼來使用TPL Dataflow，並且整體吞吐量遠遠低於原始代碼。我想看看TPL代表我選擇了什麼選擇來理解它爲什麼要慢得多。

Answer 1

我遇到了與您非常相似的情況。我結束了使用我的日誌數據告訴我大致每分鐘使用多少個線程。這給了我一個粗略的數字，但不是確切的。

我不相信TPL可以爲您提供遙測線程的使用。如果你想實現更精確的東西，我會建議在每個任務/線程中實現邏輯來標記共享列表的開始時間和完成時間。這裏是我如何開始的一個例子。

public class DoSomeTPLWork 
{ 
    public static void Start() 
    { 
     List<int> numberList = Enumerable.Range(1, 1000).ToList(); 

     Parallel.ForEach(numberList, number => 
      { 
       ThreadTracking.ThreadStarted(); 

       int square = number * number; 
       Console.WriteLine("Square of {0} is {1}", number, square); 

       ThreadTracking.ThreadFinished(); 
      } 
     ); 

     var threadInfo = ThreadTracking.GetThreadInfo(); 
    } 
} 

public class ThreadTracking 
{ 
    private static ConcurrentBag<ThreadInfo> _threadInfo = new ConcurrentBag<ThreadInfo>(); 

    public static void ThreadStarted() 
    { 
     var threadInfo = new ThreadInfo(Thread.CurrentThread.ManagedThreadId); 
     threadInfo.Start(); 
     _threadInfo.Add(threadInfo); 
    } 

    public static void ThreadFinished() 
    { 
     var threadInfo = _threadInfo.Where(ti => ti.ThreadId == Thread.CurrentThread.ManagedThreadId && !ti.Complete).SingleOrDefault(); 
     if(threadInfo != null) 
     { 
      threadInfo.Stop(); 
     } 
    } 

    public static List<ThreadInfo> GetThreadInfo() 
    { 
     return _threadInfo.ToList(); 
    } 
} 

public class ThreadInfo 
{ 
    public bool Complete { get; set; } 
    public int ThreadId { get; set; } 
    public DateTime? TimeStarted { get; set; } 
    public DateTime? TimeFinished { get; set; } 

    public ThreadInfo(int threadId) 
    { 
     ThreadId = threadId; 
    } 

    public void Start() 
    { 
     TimeStarted = DateTime.Now; 
     Complete = false; 
    } 

    public void Stop() 
    { 
     TimeFinished = DateTime.Now; 
     Complete = true; 
    } 
} 

中的數據，你可以看到有多少線程正在使用的任何第二，加入一些更多的方法來查詢數據或只是彈出它在Excel中發揮它給出。