草庐IT

task-switching

全部标签

c# - Task.Delay 与 DispatcherTimer?

我正在考虑将Task.Delay()用于不间断计时器,因为它更简单且可读性更强。由于我是.NET的新手,我看不出这两种代码之间有什么显着差异。你能告诉我它们之间的区别(如果有的话)吗?//CreatevariableatsomeplaceDispatcherTimertimer=newDispatcherTimer();timer.Interval=TimeSpan.FromSeconds(5);timer.Tick+=timer_Elapsed;timer.Start();//Functionotherplacevoidtimer_Elapsed(objectsender,Event

C# Tasks - 为什么在这种情况下需要 noop 行

我正在阅读交互式扩展的源代码并找到一个line我无法理解:publicstaticTaskUsingEnumerator(thisTasktask,IDisposabledisposable){task.ContinueWith(t=>{if(t.IsFaulted){varignored=t.Exception;//don'tremove!}if(t.IsFaulted||t.IsCanceled||!t.Result)disposable.Dispose();},TaskContinuationOptions.ExecuteSynchronously);returntask;}我在

c# - 为什么字符串常量上的 switch-case 语句在 Visual Studio 2019(16.0.3 之前)中需要默认值,但在 Visual Studio 2017 中不需要?

我正在VisualStudio2017编写的代码库上试用VisualStudio2019,我立即发现了一个构建问题。我有一个switchcase语句,其中根据常量字符串选择大小写。这没有默认情况,这在VisualStudio2017中很好,但在VisualStudio2019中会引发构建错误。我可以通过添加一个默认案例来解决这个问题,但我想避免代码更改,如果可能的话只更改编译器设置,以避免需要拉取请求。无论如何,最好了解问题的原因。publicclassProgram{publicconststringDatabase="MongoDB";publicstaticstringGetDb

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

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

c# - 在异步操作后立即调用 Task.Wait() 是否等同于同步运行相同的操作?

换句话说,就是vartask=SomeLongRunningOperationAsync();task.Wait();功能相同SomeLongRunningOperation();换句话说,就是vartask=SomeOtherLongRunningOperationAsync();varresult=task.Result;功能相同varresult=SomeOtherLongRunningOperation();根据Task.WaitandInlining,如果正在等待Wait的任务已经开始执行,则Wait必须阻塞。然而,如果它还没有开始执行,Wait可能能够将目标任务从它排队的调

c# - 如果线程正在等待异步操作完成,.NET Task 线程的资源是否会暂时返回池中?

我有一个做两件事的TPL任务。首先,它调用网络服务。其次,它将一些数据插入数据库。我有多达20个任务同时开始,一遍又一遍地做同样的事情。他们整天所做的就是调用Web服务并将数据插入数据库。我对.NET中的TPL还很陌生。我已经完成了一些有关后台工作进程和异步Web服务的工作。Web服务调用和数据库插入都是任务运行线程内的阻塞调用。我知道在幕后,当您使用Tasks时,.NET会为您管理一个线程池。是吗?如果我使用async和await()进行服务调用和数据库调用而不是使它们阻塞调用,线程池是否会有更多线程供其使用?我的理论(我不确定我为什么这么认为)是线程在等待阻塞的Web服务时正忙于无

c# - 如何模拟返回 Task<IList<>> 的方法?

我正在尝试对返回任务的方法进行单元测试>:voidMain(){varmockRepo=newMock();mockRepo.Setup(x=>x.GetAll()).Returns(newList(){newMyModel{Name="Test"}});//worksmockRepo.Setup(x=>x.GetAllAsync()).Returns(Task.FromResult(newList(){newMyModel{Name="Test"}}));//errorvarresult=mockRepo.Object.GetAll();result.Dump();}publicin

c# - Task.Delay().Wait() 是怎么回事?

我很困惑,为什么Task.Delay().Wait()需要4倍的时间,然后是Thread.Sleep()?例如task-00是否在仅线程9上运行并花费了2193毫秒?我知道,同步等待在任务中很糟糕,因为整个线程都被阻塞了。仅供测试。控制台应用程序中的简单测试:boolflag=true;varsw=Stopwatch.StartNew();for(inti=0;i{Console.WriteLine($"task-{cntr.ToString("00")}\tThrID:{Thread.CurrentThread.ManagedThreadId.ToString("00")},\tWa

c# - 从 Task.WhenAll 获取结果

我有多个任务返回我想使用Task.WhenAll(new[]{t1,t2,t3});调用的相同对象类型并阅读结果。当我尝试使用Task>all=awaitTask.WhenAll(newTask[]{t,t2}).ConfigureAwait(false);编译错误Cannotimplicitlyconverttype'void'to'System.Threading.Tasks.Task>两个任务都在调用类似于this的方法。privateTask>GetFiles(stringpath){files=newList();returnTask.Run(()=>{//removefor

c# - Task.Factory.FromAsync 和 BeginX/EndX 之间的区别?

在使用来自TcpClient的标准BeginRead和EndRead方法以及使用Task.Factory.FromAsync时,我有非常相似的代码。这里有一些例子..错误处理代码没有显示。Task.Factory.FromAsync:privatevoidRead(Statestate){Taskread=Task.Factory.FromAsync(state.Stream.BeginRead,state.Stream.EndRead,state.Bytes,state.BytesRead,state.Bytes.Length-state.BytesRead,state,TaskCr