task-parallel-library

0熱度

1回答

我使用.net核心和一些並行作品的任務，基本上它就像兩個生產者和一個消費者，兩個任務將寫入數據，消費者將讀取它，在tranditioanal .net代碼中，這些都是由線程完成的，我可以使用Semaphore或Mutex或EventHandle進行線程之間的同步，但是使用基於新任務的代碼時，我發現我不能再使用這些代碼，因爲不能保證異步函數將在await之後在同一個線程上恢復，所以我應該如何同步不同

-1熱度

2回答

使用CancellationTokenSource取消之前的異步任務

我需要執行async任務取消。我知道CancellationTokenSource會幫助我實現這一目標。但我無法找到合適的方法。我有一個搜索文本框，每當在文本框一用戶類型，對於每個TextChanged事件我請GetStocks方法如下圖所示， public async Task GetStocks() { var stockings = new List<Services.Mode

1熱度

1回答

爲什麼在異步函數使用Task.Run不返回任務<Task<T>>

考慮下面的代碼片段，其中MyMethod及其異步版本MyMethodAsync被稱爲以不同的方式： using System; using System.Threading.Tasks; namespace ConsoleApplication1 { class Program { static int MyMethod() { S

0熱度

4回答

從處理異常不期待已久的任務

假設我有一個主要方法的控制檯應用程序，這樣的事情： public static void Main(string[] args) { AppDomain.CurrentDomain.UnhandledException += (sender, eventArgs) => { Console.WriteLine("App Unobserved"); };

0熱度

2回答

將任務異常關聯到任務<T>響應

我剛開始使用任務。我們有一個使用請求/響應的系統設置。運行這些任務的服務接受一個擁有請求對象列表的主請求，並返回一個包含響應對象列表的主響應。所以它看起來像這樣 var MasterRequest = new MasterRequest; MasterRequest.Requests.Add(new BlueRequest); MasterRequest.Requests.Ad

0熱度

1回答

結合數據流結果

我開發了一個Dataflow管道，它讀取文件集合，併爲每個文件中的每一行執行一系列Dataflow塊。之後所有步驟已完成對文件中的每一行，我想對文件本身執行進一步的塊，但我不知道這是如何可能的。通過TransformManyBlock拆分處理很簡單，但是如何整合呢？我習慣了Apache Camel的Splitter和Aggregator功能 - 或者Dataflow的意圖和我想要的用法之間存

-1熱度

1回答

並行：ThreadStatic性質（.NET）的壽命

我想了解當ThreadStatic數據在.NET中使用並行處理時被清除。考慮以下（嚴重刪節）代碼：我的上下文類 public class AppContext { [ThreadStatic] private static Person _person; public Person Shopper { get => AppContext.

0熱度

1回答

TPL數據流SingleProducerConstrained是指源塊的數量還是它們的並行度？

TPL Dataflow SingleProducerConstrained選項是指源塊的數量還是源塊的最小總並行度？即，如果我只有一個源塊連接到使用此選項的塊，則源的MaxDegreeOfParallelism必須是1還是不是？

2熱度

2回答

如何鏈接呼叫，使用響應作爲另一個輸入

是否可以將來自async調用的響應用作另一個呼叫的輸入，並以某種方式將它們鏈接在一起。我在尋找類似： var model = new MyModel() { abc = await _service.getAbc(), def = await _service.getDef(abc) } 我不知道這是可能的，但只是詢問是否異步/任務可以處理這種情況。

0熱度

1回答

任何方式知道什麼時候BlockingCollection中的所有任務完成執行？（任務將在開始時被刪除，但如果exec想完成，我想知道）

我正在嘗試創建單個消費者和多個生產者模式。生產者將向BlockingCollection添加任務，而消費者將運行這些任務。我想知道是否有辦法知道消費者產生的所有任務的執行是否完成。 public TaskQueue(IProducerConsumerCollection<Task> workTaskCollection) { _workTaskQueue = new Bl