自.NET 4以来,任务并行库是.NET Framework的一部分。它是一组API,使开发人员能够对异步应用程序进行编程。
当ContinueWith与System.Threading.Tasks.Task一起使用时,单元测试失败
我正在尝试为我的代码添加单元测试,我使用TPL中的Task将值更新到数据库中。对于单元测试,我使用的是NUnit和Moq。以下是我项目中的一些代码片段。 * // ...
相当于Parallel.For的localInit和localFinally在MaxDegreeOfParallelism> 1时在TPL Dataflow块中使用
我有一个TransformBlock 有MaxDegreeOfParallelism = 6.我也确定了Func 传递给块的构造函数(为每个...执行)
获取错误tasks参数包含空值。参数名称:任务并行库中的任务,带有parallel.foreach
我正在尝试执行多个内部调用一些http调用的任务。问题是,当我使用Parallel.ForEach循环时,我收到错误:tasks参数包含一个空值。 ...
经过大量文章和视频后,我仍然遇到异步编程问题。我正在开发一个项目,在服务层我已经创建了所有方法async。 ...
在C#中使用gRPC时,异步调用返回AsyncUnaryCall (对于一元调用 - 当然,其他调用的返回类型略有不同)。但是,AsyncUnaryCall 确实......
我试图通过使用jQuery将表单发布到我的控制器操作方法来从javascript上传文件。我不想等待结果,并希望立即返回。这就是为什么我......
我有N个任务有自己的CancellationTokenSource。要跟踪每个任务及其CancellationTokenSource,我正在使用ConcurrentDictionary。因此,每当我需要取消某项特定任务时,我......
我目前正在使用File.WriteAllLines方法从.Net控制台应用程序中的字符串数组创建两个文本文件。 string [] data = {“Apple”,“Orange”,“Lemon”,...}; File.WriteAllLines(“1 ....
从异步任务方法抛出的异常的正常行为是保持休眠状态,直到稍后观察它们,或者直到任务被垃圾收集。我可以想到我可能想要的情况......
这是我的C#函数public async Task GetAttendance(IEnumerable 区域){try {foreach(区域中的var区域){var req = new AttendeeRequestTO(区域....
已经开始使从dataTable到List的转换更快,因为我在数据表中有20K记录并且以正常方式转换它需要5到7分钟。所以我想通过使用...来加快速度
我不明白,我已经看到.Net Framework提供了许多方法,它们同时具有异步和非异步变体。我的问题是异步方法为我提供了什么优势......
我想要执行一系列任务,每个任务都有自己的超时。我从这里借用了用于创建超时任务的扩展方法http://blogs.msdn.com/b/pfxteam/archive / ...
我有3个任务:私有异步任务 FeedCat(){}私有异步任务 SellHouse(){}私有异步任务 BuyCar(){}它们都需要先运行,然后我的代码才能继续...
我有一些音频文件(大约400GB),我想转换为不同的格式。我编写了转换代码并将其并行调用到每个目录中的每个文件,但它的运行速度有点慢(比如...
我是F#的新手,从C#开发人员的角度来理解F#中的异步。假设在C#中有以下片段:var httpClient = new HttpClient(); var response = await httpClient ....
Task.Wait(int)在调用它时,或者当Task开始运行时是否开始等待?
这是一个相当微妙的问题,但我的好奇心得到了我的好处,我无法在文档或其他地方找到答案。 Task.Wait(int millisecondsTimeout)的文档说:等待......
为什么Windows服务OnStart()中的Task.Run()会导致服务拒绝停止?
我不确定为什么这项服务拒绝停止。我在尝试更正启动服务时抛出的TimeoutException时遇到了这个问题。使用:public void OnStart(){_ startTask = Task ....
什么是制作几百万个SOAP请求并将结果保存到SqlDb的更快更好的方法
我的桌子上有一百万条记录。我想打电话给肥皂服务,我需要在不到一个小时的时间内处理所有记录。除了我应该更新我的表,插入请求和...
我有一个Windows服务,它正在使用消息传递系统来获取消息。我还在Timer类的帮助下创建了一个回调机制,这有助于我在一些后检查消息...