草庐IT

task-parallel-library

全部标签

c# - 什么时候用Task,什么时候用Thread?

我刚刚问了有关Task的问题,但意识到我实际上想问更一般的问题。有人可以总结一下任务和线程的优缺点。如何理解我应该使用任务还是线程? 最佳答案 Task是以异步方式执行某事的命令。Thread实际上是OS内核对象,它执行所请求的内容。将Task想象成一个聪明的线程聚合器/组织器,它“知道”在您的CPU上同时运行多少任务更好。它只是比多线程的常见实现更聪明(这就是为什么建议选择Microsoft的原因)。此功能可帮助您以更轻松的方式管理Threads。也看看这个ShouldiuseThreadPoolsorTaskParallelLi

c# - 如何使用 TaskCompletionSource.SetException 保留等待行为?

(这是对这个问题的新尝试,现在更好地证明了这个问题。)假设我们有一个错误任务(varfaultedTask=Task.Run(()=>{thrownewException("test");});),我们等待它。await将解压AggregateException并抛出底层异常。它将抛出faultedTask.Exception.InnerExceptions.First()。根据ThrowForNonSuccess的源代码,它将通过执行任何存储的ExceptionDispatchInfo来执行此操作,大概是为了保留良好的堆栈跟踪。如果没有ExceptionDispatchInfo,它不

c# - 如果在单独的方法中调用,为什么 Parallel.Invoke 会快得多?

我执行了3次QuickSort-Algorithm并测量了对5000万个随机数进行排序的时间:顺序(大约需要14秒)使用Parallel.Invoke()作为排序算法的相同方法(耗时约12秒)使用Parallel.Invoke()在单独的方法中(耗时约7秒)所以我的问题是:如果在单独的方法中调用,为什么Parallel.Invoke()会快得多?在我的电脑上,示例3.的速度是示例2的两倍多。2。使用Parallel.Invoke()作为排序算法的相同方法publicclassParallelQuickSort{privateconstintThreshold=100;publicsta

c# - 从未完成的任务会怎样?他们是否妥善处置?

假设我有以下类(class):classSomeClass{privateTaskCompletionSource_someTask;publicTaskWaitForThing(){_someTask=newTaskCompletionSource();return_someTask.Task;}//Othercodewhichcalls_someTask.SetResult(..);}然后在别处,我调用//Somecode..awaitsomeClassInstance.WaitForThing();//Somemorecode在调用_someTask.SetResult(..)之

c# - 如何使用 async/await OnNext/OnError/OnCompleted 方法实现 IObserver?

我正在尝试为System.Net.WebSocket编写一个扩展方法,使用ReactiveExtensions(Rx.NET)将它变成一个IObserver。你可以看到下面的代码:publicstaticIObserverToObserver(thisWebSocketwebSocket,IWebSocketMessageSerializerwebSocketMessageSerializer){//Wrapthewebsocketinaninterfacethat'salittleeasiertomanagevarwebSocketMessageStream=newWebSocket

c# - 我应该怎么做才能在 .NET 2.0 中使用 Task<T>?

.NET4.0有TPL,它包含很好的Task类来封装异步编程模型。我正在开发一个必须是.NET2.0的应用程序,但我想避免重写Task。有什么建议吗? 最佳答案 我知道你说过你不想重写Task,但实际上你可以使用闭包创建一些相当简单的东西,它的行为有点像Task对象。这是我使用的:publicdelegateRAsyncTask();publicstaticAsyncTaskBeginTask(AsyncTaskfunction){Rretv=default(R);boolcompleted=false;objectsync=new

c# - 是否应该重写所有接口(interface)以返回 Task<Result>?

我有一个简单的界面publicinterfaceSomethingProvider{publicSomethingGetSomething();}为了“使”它异步,我会这样做publicinterfaceSomethingProvider{publicTaskGetSomethingAsync();}虽然接口(interface)现在暗示GetSomething是异步的,但它允许同步执行,如果同步结果足够快,这很好。如果它阻塞,那么我可以将责任归咎于实现程序员对接口(interface)的不良实现。因此,如果后一个接口(interface)由足够快的阻塞实现来实现,则后一个接口(int

c# - 并行运行多个 EntityFramework 数据库查询

我正在尝试并行运行3个数据库查询,但我不确定我的操作是否正确。我创建了3个函数,每个函数都对数据库进行查询。privatestaticasyncTaskgetAccountCodeAsync(stringdeviceId){longdeviceIdLong=long.Parse(deviceId);using(vardb=newNetworksEntities()){returndb.Devices.Where(x=>x.DeviceId==deviceIdLong).Select(x=>x.AccountCode).FirstOrDefault();}}privatestaticas

c# - 具有 Task.Run 性能的 ASP.NET Web API 2 异步操作方法

我正在尝试对几个ASP.NETWebAPI2.0端点进行基准测试(使用Apache基准测试)。其中一个是同步的,一个是异步的。[Route("user/{userId}/feeds")][HttpGet]publicIEnumerableGetNewsFeedItemsForUser(stringuserId){return_newsFeedService.GetNewsFeedItemsForUser(userId);}[Route("user/{userId}/feeds/async")][HttpGet]publicasyncTask>GetNewsFeedItemsForUse

c# - AttachedToParent 任务混淆

我无法理解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