草庐IT

dynamic-parallelism

全部标签

c# - 如何使用 Dynamic LINQ 使用 GroupBy

我正在尝试使用DynamicLINQ执行GroupBy,但无法使其正常工作。这是一些说明问题的示例代码:ListlistAlbums=newList();for(inti=0;imydata=listAlbums.AsQueryable();intcount=mydata.Count();//varmydataGrouped=mydata.GroupBy(a=>a.Shop);//我意识到我在GroupBy重载中遗漏了“elementSelector”,但我想做的就是最终得到(在这种情况下)两组dtoMyAlbum对象,所以我希望为所有集合选择所有元素。.我该怎么做?

c# - Parallel Linq - 使用比处理器更多的线程(对于非 CPU 绑定(bind)任务)

我正在使用并行linq,我正在尝试使用如下基本代码同时下载许多url:intthreads=10;Dictionaryresults=urls.AsParallel(threads).ToDictionary(url=>url,url=>GetPage(url);由于下载网页受网络限制而不是CPU限制,因此使用比我的处理器/内核数量更多的线程是非常有益的,因为每个线程的大部分时间都花在等待网络catch。然而,根据在我的双核机器上运行threads=2与threads=10具有相同性能的事实判断,我认为发送到AsParallel的线程数受限于核心数。有什么方法可以覆盖这种行为吗?是否有

c# - Parallel.For 和 Break() 的误解?

我正在研究For循环中的并行中断。看完this和this我还有一个问题:我希望这段代码:Parallel.For(0,10,(i,state)=>{Console.WriteLine(i);if(i==5)state.Break();}最多生成6个数字(0..6)。不仅他没有这样做,而且结果长度不同:023514860135420135642非常烦人。(Break(){after5}到底在哪里??)于是我看了一下msdnBreakmaybeusedtocommunicatetotheloopthatnootheriterationsafterthecurrentiterationnee

c# - Stop vs Break in Parallel.For

我很难理解loopState.Stop()和loopState.Break()。我已经阅读了MSDN和几篇关于它的帖子,但我仍然感到困惑。我的理解是,每个迭代分区程序都为线程提供剩余索引以供处理,loopState.Stop()停止所有线程,loopState.Break()停止当前线程线程。但是让我们考虑以下情况:Parallel.For(0,100,(i,loopState)=>{if(i>=10)loopState.Break();Debug.Write(i);});对于这个循环我有以下结果:02512345678910我不知道为什么结果中有10和25个数字。有人可以帮忙吗?附言

c# - 在 Parallel.For 中发送多个 WebRequest

我想发送多个WebRequest。我使用了Parallel.For循环来执行此操作,但该循环运行一次,第二次在获得响应时出错。错误:Theoperationhastimedout代码:Parallel.For(0,10,delegate(inti){HttpWebRequestrequest=(HttpWebRequest)WebRequest.Create(newUri("http://www.mysite.com/service"));stringdataToSend="Data";byte[]buffer=System.Text.Encoding.GetEncoding(1252

c# - 如何使用动态LINQ(System.Linq.Dynamic)进行LIKE操作?

任何人都可以告诉我如何使用System.Linq.Dynamic来使用LIKE运算符吗??我需要在我的动态where查询中添加多个LIKE表达式/*varquery=db.Customers.Where("CityNameLike@0orCityNameLike@1","London","USA")*/varquery=db.Customers.Where("CityNameLike@0orCityNameLike@1%","London","USA")谢谢你 最佳答案 尝试简单地使用“CityName.Contains(@1)”,

c# - Task.Factory.StartNew 或 Parallel.ForEach 用于许多长时间运行的任务?

这个问题在这里已经有了答案:9年前关闭。PossibleDuplicate:Parallel.ForEachvsTask.Factory.StartNew我需要在ThreadPool中运行大约1,000个任务每晚一次(这个数字将来可能会增加)。每个任务都在执行长时间运行的操作(从Web服务读取数据)并且是非CPU密集型.AsyncI/O不是此特定用例的选项。给定一个IList参数,我需要DoSomething(stringx).我试图在以下两个选项之间进行选择:IListtasks=newList();foreach(varpinparameters){tasks.Add(Task.F

c# - 如何使用Task Parallel Library(TPL)实现重试逻辑

这个问题在这里已经有了答案:关闭10年前。PossibleDuplicate:Retryataskmultipletimesbasedonuserinputincaseofanexceptionintask我正在寻找一种在TPL中实现重试逻辑的方法。我想要一个通用的函数/类,它能够返回一个任务,该任务将执行给定的操作,并且在出现异常的情况下将重试该任务,直到给定的重试次数为止。我尝试使用ContinueWith并在出现异常时让回调创建一个新任务,但它似乎只适用于固定数量的重试。有什么建议吗?privatestaticvoidMain(){TasktaskWithRetry=Create

c# - Parallel.ForEach 丢失数据

Parallel.ForEach有助于提高性能,但是,我发现数据丢失了。已尝试-变量结果、处理数据为ConcurrentBag1)Parallel.ForEach(results,()=>newConcurrentBag(),(n,loopState,localData)=>{returnProcessData(n);//ProcessDatacomplicatedbusinesslogic},(localData)=>AddRows(localData,processedData,obj));2)awaitTask.Run(()=>Parallel.ForEach(results,i

C# 4.0 'dynamic' 没有设置 ref/out 参数

我正在试验DynamicObject。我尝试做的一件事是设置ref/out参数的值,如下面的代码所示。但是,我无法正确设置Main()中的i和j的值(即使它们在TryInvokeMember())。有谁知道如何使用ref/out参数调用DynamicObject对象并能够检索方法中设置的值?classProgram{staticvoidMain(string[]args){dynamicproxy=newProxy(newTarget());inti=10;intj=20;proxy.Wrap(refi,refj);Console.WriteLine(i+":"+j);//Print"