草庐IT

PARALLEL_CASE

全部标签

c# - List<Object> 上的 Parallel.ForEach 线程安全

就线程安全而言,可以这样做还是我需要使用不同的集合?ListfileInfo=getList();Parallel.ForEach(fileInfo,fileMember=>{//ModifyeachfileMember} 最佳答案 只要您只是修改传递给方法的项目的内容,就不需要锁定。(当然前提是列表中没有重复引用,即对同一FileMemberEntity实例的两个引用。)如果需要修改列表本身,创建一个可以迭代的副本,修改列表时使用锁:ListfileInfo=getList();Listcopy=newList(fileInfo)

c# - 使用 Parallel.ForEach() 线程安全吗?

本质上,我正在处理这个:vardata=input.AsParallel();Listoutput=newList();Parallel.ForEach(data,line=>{StringoutputLine="";//**Dosomethingwith"line"andstoreresultin"outputLine"**//Additionally,therearesomethis.InvokestatementsforupdatingUIoutput.Add(outputLine);});输入是List目的。ForEach()语句对每个值进行一些处理,更新UI,并将结果添加到o

c# - 如何在 Parallel.For 中配置最大线程数

这是微软为并行for提供的示例,我想知道如何为这段代码配置最大线程数。//Abasicmatrixmultiplication.//Parallelizetheouterlooptopartitionthesourcearraybyrows.System.Threading.Tasks.Parallel.For(0,matARows,i=>{for(intj=0;j 最佳答案 您需要指定一个ParallelOptions具有MaxDegreeOfParallelism的值:例如:Parallel.For(0,10,newParall

c# - 嵌套泛型 : Why can't the compiler infer the type arguments in this case?

当我遇到一个我不理解的类型推断错误时,我正在玩一个业余项目。我已将其简化为以下简单示例。我有以下类和函数:classFoo{}classBar{}classBaz{}staticT2F(Funcf){returndefault(T2);}staticT3G(Func>f){returndefault(T3);}现在考虑以下示例://1.Fwithexplicittypearguments-FineF(x=>newBar());//2.Fwithimplicittypearguments-Alsofine,compilerinfersF((Foox)=>newBar());//3.Gwi

c# - 如何在子类的工厂方法中避免 switch-case

假设我们有一组类(卡片,为了它),我们需要根据一些标识符来实例化它们。工厂方法看起来像这样:publicCardGetCard(intcardNumber){switch(cardNumber){case13:returnnewKing();case12:returnnewQueen();case11:returnnewJack();}//...}我想要的是避免这个开关。为什么?也许我想在功能中重用这个比较。我想出的是这样的:privateDictionarycardTypes={{13,typeof(King)},{12,typeof(Queen)},{11,typeof(Jack)

c# - Parallel.Foreach + yield 返回?

我想像这样使用并行循环处理一些东西:publicvoidFillLogs(IEnumerablecomputers){Parallel.ForEach(computers,cpt=>{cpt.Logs=cpt.GetRawLogs().ToList();});}好的,它工作正常。但是,如果我希望FillLogs方法返回一个IEnumerable怎么办?publicIEnumerableFillLogs(IEnumerablecomputers){Parallel.ForEach(computers,cpt=>{cpt.Logs=cpt.GetRawLogs().ToList();yie

c# - "SqlConnection does not support parallel transactions"什么时候发生?

我有很多相当有效的代码已经在这里好几个月了,今天我看到记录了以下异常:System.InvalidOperationExceptionSqlConnectiondoesnotsupportparalleltransactions.atSystem.Data.SqlClient.SqlInternalConnection.BeginSqlTransaction(IsolationLeveliso,StringtransactionName)atSystem.Data.SqlClient.SqlConnection.BeginTransaction(IsolationLeveliso,St

c# - Task.WaitAll 方法与 Parallel.Invoke 方法

我有示例代码来比较并行方法和任务方法的处理时间。本实验的目的是了解它们的工作原理。所以我的问题是:为什么Parallel比Task工作得更快?我的结果是否意味着我应该使用Parallel而不是Task?我应该在哪里使用Task和Parallel?与并行相比,使用任务有什么好处?Task是否只是ThreadPool.QueueUserWorkItem方法的包装?publicTaskSomeLongOperation(){returnTask.Delay(3000);}staticvoidMain(string[]args){Programp=newProgram();Listtasks=

c# - AsParallel.ForAll 与 Parallel.ForEach

下面的代码片段之间有什么区别吗?如果是,是什么?myList.AsParallel().ForAll(i=>{/*DOSOMETHING*/});和Parallel.ForEach(mylist,i=>{/*DOSOMETHING*/});主线程会等待所有子线程完成吗?在MVC应用程序中,如果我在我的Controller操作中进行并行处理,那么在主线程完成后子线程会发生什么。它们会被中止还是会在主线程完成后完成? 最佳答案 Parallel.ForEach()正是为这种代码设计的。另一方面,ForAll()旨在用于(可能很复杂的)P

c# - Task.Factory.StartNew 与 Parallel.Invoke

在我的应用程序中,我并行执行了几十到几百个操作(这些操作没有返回值)。哪种方法是最佳的:在foreach循环中使用Task.Factory.StartNew迭代Action数组(Action[])Task.Factory.StartNew(()=>someAction());使用Parallel类,其中actions是Action数组(Action[])Parallel.Invoke(actions);这两种方法是否等效?对性能有影响吗?编辑我已经执行了一些性能测试,在我的机器上(每个2个CPU2个内核)结果似乎非常相似。我不确定它在1个CPU等其他机器上会是什么样子。我也不确定(不知