草庐IT

task-parallel-library

全部标签

c# - 使用 ParallelFor 循环时索引超出范围异常

这是一个非常奇怪的情况,首先是代码......编码privateListWorksheetToDataTableForInvoiceCTN(ExcelWorksheetexcelWorksheet,intmonth,intyear){inttotalRows=excelWorksheet.Dimension.End.Row;inttotalCols=excelWorksheet.Dimension.End.Column;DataTabledt=newDataTable(excelWorksheet.Name);//for(inti=1;i{DataRowdr=null;if(i>1){

c# - 在 c# Parallel.ForEach 中的 List.Add() 上出现 "Index out of bounds"错误

这是代码Listsomething=newList();Parallel.ForEach(anotherList,r=>{..dosomeworksomething.Add(somedata);});Indexoutofbounds错误大约每百次运行1次。有没有办法防止由线程引起的冲突(我假设)? 最佳答案 为了防止出现此问题,您可以使用ConcurrentQueue而不是List或并行部分中的类似并发集合。并行任务完成后,您可以将其放入List中。.有关详细信息,请查看System.Collections.Concurrent命名

c# - Parallel.ForEach 不断产生新线程

当我在我的程序中使用Parallel.ForEach时,我发现有些线程似乎永远不会结束。事实上,它一遍又一遍地产生新线程,这是我没有预料到也绝对不希望出现的行为。我能够使用以下代码重现此行为,就像我的“真实”程序一样,它们都大量使用处理器和内存(.NET4.0代码):publicclassNode{publicNodePrevious{get;privateset;}publicNode(Nodeprevious){Previous=previous;}}publicclassProgram{publicstaticvoidMain(string[]args){DateTimestar

c# - 如何运行多个任务,处理异常并仍然返回结果

我正在更新我的并发技能。我的问题似乎相当普遍:从多个Uris读取、解析和处理结果等。我有ConcurrencyinC#Cookbook.有几个使用GetStringAsync的示例,例如staticasyncTaskDownloadAllAsync(IEnumerableurls){varhttpClient=newHttpClient();vardownloads=urls.Select(url=>httpClient.GetStringAsync(url));Task[]downloadTasks=downloads.ToArray();string[]htmlPages=awai

c# - 将两个并行任务的结果合并到一个列表中

我想将2个任务的结果合并到一个列表集合中。确保-我想并行运行这两种方法。代码:ListtotalEmployees=newList();方法一:publicasyncTask>SearchEmployeeFromDb();方法二:publicasyncTask>GetEmployeeFromService();现在,我想将这两个方法的结果保存在totalEmployees字段中,而且这两个方法应该异步运行。 最佳答案 虽然许多答案都很接近,但最干净、最有效的选择是使用Task.WhenAll结合SelectMany:asyncTas

c# - 等待 Task.Run 与等待

我在网上搜索过很多关于Task.Run和awaitasync的问题,但是有一个具体的使用场景我不太明白其中的区别。我相信场景非常简单。awaitTask.Run(()=>LongProcess());对比awaitLongProcess());LongProcess是一个异步方法,其中包含一些异步调用,例如使用awaitExecuteReaderAsync()调用db。问题:在这个场景下两者有什么区别吗?感谢任何帮助或输入,谢谢! 最佳答案 Task.Run可以将要处理的操作发布到不同的线程。这是唯一的区别。这可能有用-例如,如果L

c# parallel foreach 循环查找索引

我正在尝试读取文本文件中的所有行并计划显示每一行信息。如何找到循环内每个项目的索引?string[]lines=File.ReadAllLines("MyFile.txt");Listlist_lines=newList(lines);Parallel.ForEach(list_lines,(line,index)=>{Console.WriteLine(index);//Console.WriteLine(list_lines[index]);Console.WriteLine(list_lines[0]);});Console.ReadLine(); 最

c# - await 和 async 与 Task 并行库的区别

任务并行库和await、async有什么区别。引入await和async的必要性是什么?我看到TPL是C#4.0的一部分,await/async是C#5.0的一部分,但除此之外,基本区别是什么。引入这个新关键字的必要性是什么? 最佳答案 任务并行库是为parallelprogramming设计的-当您有很多工作要做并且想在多个线程之间拆分这些工作以便您可以使用所有CPU内核时。TPL最适合CPU密集型工作。Async和await适用于asynchronousprogramming-当你有一个操作(或多个操作)将在未来完成,而你想同时

c# - 现有的类似于Parallel.For的LINQ扩展方法?

这个问题在这里已经有了答案:关闭9年前。PossibleDuplicate:LINQequivalentofforeachforIEnumerableienumerable的linq扩展方法非常方便……但如果您只想对枚举中的每个项目应用一些计算而不返回任何内容,那么就没那么有用了。所以我想知道也许我只是错过了正确的方法,或者它是否真的不存在,因为如果它可用的话我宁愿使用内置版本......但我还没有找到一个:-)我可以发誓某处有一个.ForEach方法,但我还没有找到它。与此同时,我确实编写了自己的版本以防它对其他人有用:usingSystem.Collections;usingSys

c# - Task.Delay 永远不会完成

以下代码将永远卡住。publicasyncTaskDoSomethingAsync(){awaitTask.Delay(2000);}privatevoidButton_Click(objectsender,RoutedEventArgse){DoSomethingAsync().Wait();//Task.Delay(2000).Wait();}如果我将调用切换到带有注释掉的代码的DoSomethingAsync,它会按预期运行。我怀疑嵌套等待以某种方式导致了死锁,但我不确定原因或如何修复它。 最佳答案 假设Button_Clic