当某些任务可能被取消时，等待多个任务
同时完成的技术是什么？
相关·内容
2回答
我正在尝试等待多个任务，我预计其中一些任务可能会被取消。我使用this source作为灵感的来源，让WhenAll相应地处理取消的任务…… 然而，如果这些任务都没有被取消，这反过来也会抛出一个异常！我可以通过从最后一行中删除ContinueWith来解决这个问题，但是如果任务被取消，WhenAll将失败并返回相同的错误。 当一
浏览 30提问于2021-02-02得票数 0
回答已采纳
1回答
什么时候可以取消异步任务？或者，更普遍地说，asyncio循环什么时候可以切换到不同的任务？我真的很难在异步程序中使用取消，因为我不知道什么时候可以抛出CancelledError。__aenter__期间被取消会发生什么？如果任务在aenter返回时被取消，则不会调用aexit。
任务是否可以在退出异步函数时被取消？()中运行的任务</
浏览 8提问于2022-06-23得票数 0
我想知道如何使用以Task.WaitAll为参数的CancellationToken重载，例如
文档称，CancellationToken参数是“等待任务完成时观察的CancellationToken”既然Task.WaitAll是一个阻塞操作，你怎么可能在那个操作中“观察”它呢？此外，它还说：“cancellationToken参数用于取消等待操作。如果它被取消，等待返回false。”但是，它还在其他地方说，当OperationCa
浏览 4提问于2015-01-28得票数 5
回答已采纳
我有一个使用相同CancellationTokenSource运行任务的列表。即使当前线程处于等待状态，任务也可能被另一个任务取消。这是正常的行为。但是，当当前线程处于等待状态，另一个任务取消任务时，WaitAll抛出Cancella
浏览 3提问于2016-11-14得票数 5
回答已采纳
我正在尝试两种方法来阻止无限循环的运行：
虽然supervisor_2不会在中断时抛出任何错误
浏览 14提问于2017-05-05得票数 7
回答已采纳
我想知道如何将一个可观察到的类似于switchMap的流转换成多个(有限)流，而不是局限于单个活动流。其目的是使多个任务同时工作，达到某些任务计数的限制，并允许使用FIFO队列策略启动新任务，这意味着任何新任务都将立即启动，队列中最老的任务将被取消。switchMap将为源的每个发射创建可观测的，并将取消以前运行的可观测流(一旦创建了新的)，我希望实现类似的目标，但允许具有某种级别的并发性(如flatMap)，这意味
浏览 2提问于2017-01-30得票数 2
回答已采纳
2回答
我正在使用任务并行库，并且正在使用任务工厂来创建和启动一个新任务列表。在启动任务之后，我调用了Task.WaitAll(...)等待所有任务返回。代码类似于下面的代码。当我的任务返回并完成时，如果它们满足一定的条件，结果将被聚合到一个列表中，以便稍后处理。当每个任务都在运行时，可能会抛出某些异常，这将取消将任务结果添加到聚合列表的资格。我希望能够
浏览 2提问于2012-07-24得票数 2
1回答
Console.WriteLine("Task1 Status:{0}", t1.Status);在这里，我取消了任务，然后状态显示了RanToCompletion，但是如果我删除了对这两个任务的等待，那么它将显示已取消的状态.当我要取消任务时，我期待着在任何情况下取消的状态.
编辑：通过抛出O
浏览 1提问于2012-08-26得票数 3
我有一个可等待的对象，它不是Task (例如，安装了RX的IObservable<T> )。我想创建一个Task，如果提供的CancellationToken被取消，它将被取消，否则将返回可等待对象的结果。(false); return obsTask.Result;使用这种方法，我需要为我将要使用的每个可等待的类型重载我的猜测是，INotifyCompletion接口可
浏览 0提问于2015-10-19得票数 4
我有一个任务，它要求我安排任务，并在某个事件发生时删除它们。我使用ScheduledThreadPoolExecutor来调度任务，这非常简单。但是，我发现了两种取消待决项目的方法，这两种方法看起来都有点奇怪。那么，这些代码片段会做我想让它们做的事情吗？有没有更好/更干净的方法呢？
浏览 0提问于2012-09-25得票数 10
回答已采纳
我正在使用Task.WhenAll等待倍数任务。当其中一个生成异常时，我希望Task.WhenAll (或其他任何等待倍数任务的方式)立即取消其他任务并引发异常。提前感谢
浏览 3提问于2017-01-27得票数 4
回答已采纳
在Apache气流中，假设我希望设置一个包含3个任务的DAG。当DAG被调度时，我希望任务A运行，然后是task (当A完成时)。但是，我希望任务C只在某些外部代码触发它时才运行(它不应该轮询和等待外部条件得到满足；我希望它等待直到接收到外部请求才开始执行，但前提是A和B已经完成)。我也不想为任务<
浏览 1提问于2022-03-05得票数 0
4回答
我正在使用Java ExecutorService框架提交可调用的任务以供执行。这些任务与web服务通信，web服务超时时间为5分钟。但是，我已经看到在某些情况下超时被忽略了，线程“挂起”在API调用上-因此，我想取消所有耗时超过5分钟的任务。
目前，我有一个未来的列表，我迭代它们并调用future.get，直到所有的任务完成。现在，我已经看到future.get重载的方法需要一个超时，当任务在那个窗口中没有完成时抛出一个超时。因此，
浏览 0提问于2013-08-30得票数 4
回答已采纳
在实践中的Java并发性(Brian Goetz)中说明了这一点(重点是我的)：
因此，据我所知:如果我得到一个InterruptedExceptio
浏览 2提问于2015-08-13得票数 2
回答已采纳
在处理RPC请求时，aioamqp回调将生成负责网络IO的任务。这些任务可以被认为是后台任务，对于AMQP上的流网络响应而言，这些任务将无限期地运行(在本例中，一个RPC请求触发RPC响应和数据流)。我注意到，在我的原始代码中，网络任务将在看似随机的时间间隔后(在完成之前)被销毁，然后异步将打印以下警告：“任务已被销毁，但它正在挂起”。这个问题类似于这里描述的问题：。理想情况下，我希望在RPC回调中调用等待任
浏览 10提问于2017-06-01得票数 5
我怎么知道打给WebClient.DownloadFileTaskAsync的电话是否取消了？WebClient webclient = new WebClient();然后，在其他地方取消电话，包括：当等待继续的时候，我怎么知道它是成功的还是被取消的？
浏览 2提问于2014-07-31得票数 2
回答已采纳
2回答
someTask // clean upAsync.Start (a, cancellationTokenSource.Token)问题似乎在于a正在等待的
浏览 5提问于2015-05-23得票数 3
回答已采纳
Elapsed: 00:00:02为什么Async.StartChild会有这种行为？
浏览 0提问于2019-04-13得票数 2
1回答
我想用异步异步运行这两个测试，一旦其中一个测试失败，父函数应该返回fail并取消另一个测试。
我对异步通信很陌生，我用条件阅读了一些示例，但不知道如何用条件编写异步。
浏览 1提问于2018-04-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
