草庐IT

task-parallel-library

全部标签

c# - 将任何给定的函数转换为可等待的任务

以下代码的目标是将任何给定函数转换为可等待函数。这个想法是在从数据库中获取数据时使用它,从而使代码可以灵活地使用同步获取函数(我当前ORM的强加),或者使用与异步完全相同的函数。我知道代码背后的概念可能有很多问题。到目前为止,我只是试图摆脱编译器错误,以便我可以运行代码并检查行为。但是我当然愿意事先讨论这个概念,如果它背后的整个想法是错误的,那么我会更有效地利用我的时间寻找另一个解决方案。asyncstaticvoidMain(){//Thefollowinglinegivesacompilererror://Error1Thebestoverloadedmethodmatchfor'

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# - 发送邮件异步 : An asynchronous module or handler completed while an asynchronous operation was still pending

在使用SendMailAsync时出现以下错误:Anasynchronousmoduleorhandlercompletedwhileanasynchronousoperationwasstillpending我的代码:publicstaticasyncTaskSendEmail(MessageContentmessageContent,stringemailBody){SmtpClientsmtpClientNoSend=newSmtpClient();awaitsmtpClientNoSend.SendMailAsync(mailMessage);}来自Controller的调用:

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# - 如何在 .net 3.5 中获得 Task<T> 的等价物?

我有一些代码正在使用Task它会在短时间内延迟从串行读取操作返回结果,如下所示:voidReturnResponseAfterAShortDelay(){if(delayedResponseCancellationTokenSource!=null)delayedResponseCancellationTokenSource.Cancel();//Cancelanypendingoperationsandstartanewone.delayedResponseCancellationTokenSource=newCancellationTokenSource();log.InfoFor

c# - 链接两个函数 () -> Task<A> 和 A->Task<B>

不知道是不是我对TPL的理解有误,但是我很难理解如何获得以下内容:我有两个功能TaskgetA(){...}TaskgetB(Aa){...}这似乎经常发生:我可以异步地得到一个A。给定一个A,我可以异步地得到一个B。我想不出在TPL中将这些函数链接在一起的正确方法。这是一个尝试:TaskCombined(){Taskta=getA();Task>ttb=ta.ContinueWith(a=>getB(a.Result));returnttb.ContinueWith(x=>x.Result.Result);}ContinueWith是我感到困惑的地方。返回的类型是“双重任务”,Tas

c# - 了解一行中使用的 Task.Run + Wait() + async + await 的使用

我是C#新手,所以我在理解一些概念时遇到了困难,并且遇到了一段我不太理解的代码:staticvoidMain(string[]args){Task.Run(async()=>{awaitSomeClass.Initiate(newConfiguration());}).Wait();while(true);}据我了解,这会运行一个启动方法的任务。此方法运行,然后,一旦完成,就会进入无限循环等待。感觉要么是代码没看懂,要么是我没理解对。谢谢 最佳答案 你可以把它分成几个部分:async()=>{awaitSomeClass.Initi

c# -/平台 :anycpu32bitpreferred is not a valid setting for option/target:library or/target:module

我创建了一个Windows服务项目,后来决定将其输出类型更改为类库,这样我就可以将服务类包含在另一个项目中,该项目将创建要作为服务安装的.exe。但是现在,当我尝试构建第一个项目时,它失败并出现错误:/platform:anycpu32bitpreferredisnotavalidsettingforoption/target:libraryor/target:module我该如何解决这个问题? 最佳答案 尝试卸载项目(在解决方案资源管理器中右键单击)编辑.csproj(右键单击解决方案资源管理器)删除true重新加载项目。