首頁 >後端開發 >C++ >TPL資料流如何限制並發非同步任務?

TPL資料流如何限制並發非同步任務?

Mary-Kate Olsen
Mary-Kate Olsen原創
2025-01-22 20:22:12595瀏覽

How Can TPL Dataflow Limit Concurrent Asynchronous Tasks?

使用TPL Dataflow限制非同步任務並發數

本文探討如何利用TPL Dataflow有效率地限制並發非同步任務的數量,同時充分利用多執行緒優勢。與使用BlockingCollectionSemaphoreSlimThrottleTasksAsync方法相比,TPL Dataflow提供了更簡潔的解決方案。

透過配置TransformBlockMaxDegreeOfParallelism屬性,我們可以直接指定並發執行任務的最大數量。將URL加入TransformBlock中,它會非同步處理這些URL。處理完成後,即可取得結果。

<code class="language-csharp">var downloader = new TransformBlock<string, HttpResponse>(
    url => Download(url),
    new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 50 }
);

var buffer = new BufferBlock<HttpResponse>();
downloader.LinkTo(buffer);

foreach (var url in urls)
    downloader.Post(url);

downloader.Complete();
await downloader.Completion;

IList<HttpResponse> responses;
if (buffer.TryReceiveAll(out responses))
{
    // 处理结果
}</code>

要注意的是,TransformBlock會緩衝輸入和輸出。因此,我們使用BufferBlock與它連接,防止TransformBlock在所有輸出項被消費之前阻塞。 BufferBlock.TryReceiveAll方法用於在TransformBlock完成後檢索所有結果。

以上是TPL資料流如何限制並發非同步任務?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn