c# – 监视超时的同步方法
发布时间:2020-12-15 03:41:58 所属栏目:百科 来源:网络整理
导读:如果同步方法执行时间太长,我正在寻找一种有效的方法来抛出超时异常.我看到一些样本,但没有什么比我想要的更好. 我需要做的是 检查同步方法是否超出其SLA 如果它引发超时异常 如果执行时间太长,我不必终止同步方法. (多个故障将跳闸并防止级联故障) 到目前为
如果同步方法执行时间太长,我正在寻找一种有效的方法来抛出超时异常.我看到一些样本,但没有什么比我想要的更好.
我需要做的是 >检查同步方法是否超出其SLA 如果执行时间太长,我不必终止同步方法. (多个故障将跳闸并防止级联故障) 到目前为止,我的解决方案如下.请注意,我通过了一个CancellationToken到sync方法,希望它会超时取消取消请求.此外,我的解决方案返回一个任务,然后可以等待我的呼叫代码所需的等等. 我关心的是,这个代码每个监控方法都创建了两个任务.我认为TPL会很好的管理,但我想确认. 这有道理吗有没有更好的方法来做到这一点? private Task TimeoutSyncMethod( Action<CancellationToken> syncAction,TimeSpan timeout ) { var cts = new CancellationTokenSource(); var outer = Task.Run( () => { try { //Start the synchronous method - passing it a cancellation token var inner = Task.Run( () => syncAction( cts.Token ),cts.Token ); if( !inner.Wait( timeout ) ) { //Try give the sync method a chance to abort grecefully cts.Cancel(); //There was a timeout regardless of what the sync method does - so throw throw new TimeoutException( "Timeout waiting for method after " + timeout ); } } finally { cts.Dispose(); } },cts.Token ); return outer; } 编辑: 使用@ Timothy的答案我现在使用这个.虽然代码不是很明显,但是更清楚了.谢谢! private Task TimeoutSyncMethod( Action<CancellationToken> syncAction,TimeSpan timeout ) { var cts = new CancellationTokenSource(); var inner = Task.Run( () => syncAction( cts.Token ),cts.Token ); var delay = Task.Delay( timeout,cts.Token ); var timeoutTask = Task.WhenAny( inner,delay ).ContinueWith( t => { try { if( !inner.IsCompleted ) { cts.Cancel(); throw new TimeoutException( "Timeout waiting for method after " + timeout ); } } finally { cts.Dispose(); } },cts.Token ); return timeoutTask; } 解决方法
如果你有一个任务叫做任务,你可以这样做:
var delay = Task.Delay(TimeSpan.FromSeconds(3)); var timeoutTask = Task.WhenAny(task,delay); 如果timeoutTask.Result结束为任务,那么它没有超时.否则,它是延迟,它超时. 我不知道这是否与你所实现的相同,但它是内置的方法. (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |