我同意你的推理，因為這項工作看起來是受延遲或帶寬限制的網絡請求，所以將并發限制在CPU內核的數量上沒有什么意義。 您可能需要進行一些測試以找到合適的maxCount值。但理想情況下，你應該有一個符合實際情況的系統。老實說，我不確定最好的設計是什么，但我想看看數據流是否可以提供更好的方法來限制并發性?；蛘咧辽賹⒃撝底鳛榕渲霉_，以便稍后進行調整。

謝謝@Charlieface。我想為了thread的安全，我現在可以接受仔細處理dispose（）了。 我遇到了一個相關的話題，以防有人感興趣：在等待掛起的操作取消時處理一個信號量lim是否安全？

我想說，如果你希望StopAsync被并行調用，那么這些措施是值得的。 雖然我在你的代碼中看到了另一個潛在的缺陷——你在開始和停止之間共享_clientWebSocket和_tokenSource，所以你可能會在下一種情況下結束： Thread1調用StartAsync并初始化_clientWebSocket和_tokenSource并存在信號量 Thread2調用StartAsync并覆蓋_clientWebSocket和_tokenSource Thread1StopAsync調用StopAsync，它將停止Thread2創建的ClientWebSocket，但沒有人會關閉Thread1創建的ClientWebSocket

為什么我使用semafore需要更多的時間（最多3倍）？ 可能是因為它限制了并發IO操作的數量。使用信號量會將并發調用的數量限制為處理器的數量，然而，由于它涉及IO，大部分時間將只是等待，不需要處理器時間。因此，將并發性限制在內核數量上是沒有意義的。嘗試增加maxCount，看看這是否有助于提高性能。 在這種情況下，我應該使用semafore嗎？ 由于速度較慢，而且似乎不需要任何threadsafety原因，答案可能是否定的。 我應該什么時候使用semafore？ 我很少使用信號燈。我所知道的最令人信服的原因是，如果我需要一個異步鎖，即一個maxcount為1的信號量。它有專門的用例，但在大多數情況下，我發現負責同步的高級原語更有用。 我可能建議您閱讀DataFlow，這可能會讓您設置一個更適合use-case的異步處理管道。

可以使用Lazy簡化初始化代碼 static Lazy<SemaphoreSlim> pool = null;public Handler(IConfiguration configuration){ int poolSize = configuration.GetValue("PoolSize", 3); pool = new Lazy<SemaphoreSlim>(() => new SemaphoreSlim(10), LazyThreadSafetyMode.ExecutionAndPublication);} 它的工作原理與您現有的代碼類似，但我總是更喜歡在可用時使用框架方法來進行thread-related工作，因為這些方法是由工程師優化的，他們對threading的理解遠遠好于普通bear。

假設我有一個進程，它每分鐘運行一次并執行一些I/O操作。。。假設2threads花費了超過一分鐘的時間，并且在一分鐘后該進程再次運行時，它應該同時執行3threads，因為2threads已經在執行一些操作。 這種問題描述有點常見，但是很難正確地編寫代碼。這是因為您有一個polling-style計時器（基于時間），它試圖定期調整節流機制。正確地做這件事是相當困難的。 所以，我建議的第一件事就是改變問題的描述?？紤]讓輪詢機制讀取所有未完成的工作，然后從那里使用普通的限制(e.g.，然后添加到execution-constrainedActionBlock）。 也就是說，如果您希望繼續沿著更復雜的路徑前進，這樣的代碼可以避免Parallel和async問題： private static SemaphoreSlim _semaphoreSlim = new SemaphoreSlim(5);private async Task ExecuteAsync(){ try { var availableThreads = _semaphoreSlim.CurrentCount; if (availableThreads > 0) { var lists = await _feedSourceService.GetListAsync(availableThreads); // sel

你忘了await你的Task.Delay(2000)，所以這一行基本上什么也不做，Task.Runthread立即去寫“釋放！”，然后釋放信號量。因此，為了實現您想要的，只需等待延遲，給主要thread時間首先到達WaitAsync： SemaphoreSlim slim = new SemaphoreSlim(1);_ = Task.Run(async () =>{ await Task.Delay(2000); Console.WriteLine("Unleash!"); slim.Release();});Console.WriteLine("Waiting");await slim.WaitAsync();Console.WriteLine("Done");

我想我已經意識到我只是在等待任務的開始，而不是完成。 事實上，這是問題的核心。 你不應該為任何事情使用Task構造函數。假裝它不存在。它總是會讓你走上一條尷尬的道路。 如果您想在以后執行某個操作，則應該使用委托：Action或Func<T>用于同步工作，Func<Task>或Func<Task<T>>用于異步工作。例如，如果Method是同步的，那么您將有： public Action Operation { get; set; }...Operation = () => Method(input, sps); 然后可以使用Task.Run調用它，如下所示： public async Task ProcessAsync(){ using (SemaphoreSlim concurrencySemaphore = new SemaphoreSlim(5)) { var tasks = ThreadHandler.ThreadList.Select(async task => { await concurrencySemaphore.WaitAsync(); try { await Task.Run(() => task.Operation()); } finally { concurrencySemaphore.Re