은/닷넷에서 구조를 기다리고 4.0

Question

구조 끝내 불행하게도 아직 Microsoft는 모두 .NET 4.5 VS 2012, 그리고 그것의 릴리스 후보를 나타내 기다리고 있습니다

C# 5.0 비동기/동기 부여 이 기술들이 우리 프로젝트에 널리 채택 될 때까지 시간이 걸릴 것입니다.

스티븐 투브 (Stephen Toub)의 Asynchronous methods, C# iterators, and Tasks에서 저는 .NET 4.0에서 잘 사용될 수있는 대체물을 발견했습니다. .NET 2.0에서도이 접근법을 사용할 수있게 해주는 12 가지 구현이 있습니다.하지만 구식이 아닌 기능이 풍부하지는 않습니다.

예

그래서 지금 내 .NET 4.0 코드는 같습니다 (주석 섹션이 .NET 4.5에서 수행되는 방법을 보여줍니다) :이 작업을 수행하지만

//private async Task ProcessMessageAsync() 
private IEnumerable<Task> ProcessMessageAsync() 
{ 
    //var udpReceiveResult = await udpClient.ReceiveAsync(); 

    var task = Task<UdpAsyncReceiveResult> 
       .Factory 
       .FromAsync(udpClient.BeginReceive, udpClient.EndReceive, null); 

    yield return task; 

    var udpReceiveResult = task.Result; 

    //... blah blah blah 

    if (message is BootstrapRequest) 
    { 
     var typedMessage = ((BootstrapRequest)(message)); 

     // !!! .NET 4.0 has no overload for CancellationTokenSource that 
     // !!! takes timeout parameter :(
     var cts 
      = new CancellationTokenSource(BootstrapResponseTimeout); // Error here 

     //... blah blah blah 

     // Say(messageIPEndPoint, responseMessage, cts.Token); 

     Task.Factory.Iterate(Say(messageIPEndPoint, responseMessage, cts.Token)); 
    } 
} 

조금 못생긴 보이는

질문

.NET 4.5 CancellationTokenSource을 그를 생성하며,이 타임 아웃 시간 범위를 파라미터로하는 생성자가 존재하여지정된 기간 내에 취소합니다. .Net 4.0에서 시간 제한을 설정할 수 없으므로 .Net 4.0에서 올바른 방법은 무엇입니까?

Answer 1

async/await와 관련이 있습니까? async/await와 독립적으로 토큰 취소 방법이 필요한 것 같습니다. 이 경우 시간 초과 후 Cancel을 호출하는 Timer를 간단하게 만들 수 있습니까?

new Timer(state => cts.Cancel(), null, BootstrapResponseTimeout, Timeout.Infinite); 

편집

내 초기 반응은 위의 기본 개념이지만,보다 강력한 솔루션은 Is CancellationTokenSource.CancelAfter() leaky?에 (당신이 찾고있는 생성자 실제로 닷넷 4.5 구현을) 찾을 수있다. 다음은 해당 코드를 기반으로하는 시간 초과 토큰을 만드는 데 사용할 수있는 함수입니다.

public static CancellationTokenSource CreateTimeoutToken(int dueTime) { 
    if (dueTime < -1) { 
     throw new ArgumentOutOfRangeException("dueTime"); 
    } 
    var source = new CancellationTokenSource(); 
    var timer = new Timer(self => { 
     ((Timer)self).Dispose(); 
     try { 
      source.Cancel(); 
     } catch (ObjectDisposedException) {} 
    }); 
    timer.Change(dueTime, -1); 
    return source; 
} 

Answer 2

FWIW, 4.0 프로젝트에서 async/await을 사용할 수 있습니다. the async targeting pack 만 사용하십시오. 나를 위해 위대한 작품!

Answer 3

당신은 여전히 ​​위의 허용 대답과 매우 유사 Microsoft.Bcl.Async의 확장 방법은 CancelAfter()를 사용할 수 있습니다.

/// <summary>Cancels the <see cref="T:System.Threading.CancellationTokenSource" /> after the specified duration.</summary> 
    /// <param name="source">The CancellationTokenSource.</param> 
    /// <param name="dueTime">The due time in milliseconds for the source to be canceled.</param> 
    public static void CancelAfter(this CancellationTokenSource source, int dueTime) 
    { 
    if (source == null) 
     throw new NullReferenceException(); 
    if (dueTime < -1) 
     throw new ArgumentOutOfRangeException("dueTime"); 
    Contract.EndContractBlock(); 
    Timer timer = (Timer) null; 
    timer = new Timer((TimerCallback) (state => 
    { 
     timer.Dispose(); 
     TimerManager.Remove(timer); 
     try 
     { 
     source.Cancel(); 
     } 
     catch (ObjectDisposedException ex) 
     { 
     } 
    }), (object) null, -1, -1); 
    TimerManager.Add(timer); 
    timer.Change(dueTime, -1); 
    }