我需要做的是

>检查同步方法是否超出其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;
  }