task-parallel-library
全部标签 我刚刚问了有关Task的问题,但意识到我实际上想问更一般的问题。有人可以总结一下任务和线程的优缺点。如何理解我应该使用任务还是线程? 最佳答案 Task是以异步方式执行某事的命令。Thread实际上是OS内核对象,它执行所请求的内容。将Task想象成一个聪明的线程聚合器/组织器,它“知道”在您的CPU上同时运行多少任务更好。它只是比多线程的常见实现更聪明(这就是为什么建议选择Microsoft的原因)。此功能可帮助您以更轻松的方式管理Threads。也看看这个ShouldiuseThreadPoolsorTaskParallelLi
(这是对这个问题的新尝试,现在更好地证明了这个问题。)假设我们有一个错误任务(varfaultedTask=Task.Run(()=>{thrownewException("test");});),我们等待它。await将解压AggregateException并抛出底层异常。它将抛出faultedTask.Exception.InnerExceptions.First()。根据ThrowForNonSuccess的源代码,它将通过执行任何存储的ExceptionDispatchInfo来执行此操作,大概是为了保留良好的堆栈跟踪。如果没有ExceptionDispatchInfo,它不
我执行了3次QuickSort-Algorithm并测量了对5000万个随机数进行排序的时间:顺序(大约需要14秒)使用Parallel.Invoke()作为排序算法的相同方法(耗时约12秒)使用Parallel.Invoke()在单独的方法中(耗时约7秒)所以我的问题是:如果在单独的方法中调用,为什么Parallel.Invoke()会快得多?在我的电脑上,示例3.的速度是示例2的两倍多。2。使用Parallel.Invoke()作为排序算法的相同方法publicclassParallelQuickSort{privateconstintThreshold=100;publicsta
假设我有以下类(class):classSomeClass{privateTaskCompletionSource_someTask;publicTaskWaitForThing(){_someTask=newTaskCompletionSource();return_someTask.Task;}//Othercodewhichcalls_someTask.SetResult(..);}然后在别处,我调用//Somecode..awaitsomeClassInstance.WaitForThing();//Somemorecode在调用_someTask.SetResult(..)之
我正在尝试为System.Net.WebSocket编写一个扩展方法,使用ReactiveExtensions(Rx.NET)将它变成一个IObserver。你可以看到下面的代码:publicstaticIObserverToObserver(thisWebSocketwebSocket,IWebSocketMessageSerializerwebSocketMessageSerializer){//Wrapthewebsocketinaninterfacethat'salittleeasiertomanagevarwebSocketMessageStream=newWebSocket
.NET4.0有TPL,它包含很好的Task类来封装异步编程模型。我正在开发一个必须是.NET2.0的应用程序,但我想避免重写Task。有什么建议吗? 最佳答案 我知道你说过你不想重写Task,但实际上你可以使用闭包创建一些相当简单的东西,它的行为有点像Task对象。这是我使用的:publicdelegateRAsyncTask();publicstaticAsyncTaskBeginTask(AsyncTaskfunction){Rretv=default(R);boolcompleted=false;objectsync=new
我有一个简单的界面publicinterfaceSomethingProvider{publicSomethingGetSomething();}为了“使”它异步,我会这样做publicinterfaceSomethingProvider{publicTaskGetSomethingAsync();}虽然接口(interface)现在暗示GetSomething是异步的,但它允许同步执行,如果同步结果足够快,这很好。如果它阻塞,那么我可以将责任归咎于实现程序员对接口(interface)的不良实现。因此,如果后一个接口(interface)由足够快的阻塞实现来实现,则后一个接口(int
我正在尝试并行运行3个数据库查询,但我不确定我的操作是否正确。我创建了3个函数,每个函数都对数据库进行查询。privatestaticasyncTaskgetAccountCodeAsync(stringdeviceId){longdeviceIdLong=long.Parse(deviceId);using(vardb=newNetworksEntities()){returndb.Devices.Where(x=>x.DeviceId==deviceIdLong).Select(x=>x.AccountCode).FirstOrDefault();}}privatestaticas
我正在尝试对几个ASP.NETWebAPI2.0端点进行基准测试(使用Apache基准测试)。其中一个是同步的,一个是异步的。[Route("user/{userId}/feeds")][HttpGet]publicIEnumerableGetNewsFeedItemsForUser(stringuserId){return_newsFeedService.GetNewsFeedItemsForUser(userId);}[Route("user/{userId}/feeds/async")][HttpGet]publicasyncTask>GetNewsFeedItemsForUse
我无法理解AttachedToParent参数的工作原理。示例代码如下:publicstaticvoidMain(string[]args){TaskparentTask=Task.Run(()=>{int[]results=newint[3];Taskt1=newTask(()=>{Thread.Sleep(3000);results[0]=0;},TaskCreationOptions.AttachedToParent);Taskt2=newTask(()=>{Thread.Sleep(3000);results[1]=1;},TaskCreationOptions.Attache