/.NET yapıları bekliyor 4.0

Question

yapılar müthiş maalesef henüz Microsoft sadece her iki .NET 4.5 ve VS 2012 ve bunun bir sürüm adayı gösterilir bekliyor verisimi

C# 5.0 zaman uyumsuz/Motivasyon Bu teknolojiler projelerimizde yaygın olarak benimsenene kadar biraz zaman alacaktır.

Stephen Toub'nin Asynchronous methods, C# iterators, and Tasks numaralı sürümünde .NET 4.0'da güzel bir şekilde kullanılabilen bir değiştirme buldum. Ayrıca, biraz güncelliğini yitirmiş ve daha az özellik bakımından zengin olsa da, .NET 2.0'da bile bu yaklaşımı kullanarak bunu mümkün kılan bir düzine başka uygulama vardır.

Örnek

Yani şimdi benim .NET 4.0 kod benziyor (yorumladı bölümler de .NET 4.5 nasıl yapılır göster): iş yapar gerçi

//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)); 
    } 
} 

küçük çirkin görünüyor

soru

.NET 4.5 CancellationTokenSource oçıkan böylece, bir zaman aşımı parametre olarak zaman aralığı alan bir kurucu yoktur kullanılarakbelirli bir süre içinde iptal eder.
.Net 4.0, zaman aşımı yapamıyor, bu yüzden .Net 4.0'da bunu yapmanın doğru yolu nedir?

Answer 1

Bu gerçekten async/await ile ilgili bir şey var mı? Görünüşe göre, belirteci, beklemeden/beklemeden bağımsız olarak iptal etmenin bir yoluna ihtiyacınız var değil mi? Bu durumda, zaman aşımından sonra İptal'i çağıran bir Zamanlayıcı oluşturabilirsiniz.

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

DÜZENLEME

Benim ilk tepki yukarıdaki temel fikir, ama daha sağlam bir çözüm Is CancellationTokenSource.CancelAfter() leaky? içinde (aradığınız yapıcı aslında .Net 4.5 uygulaması) bulunabilir edilir. İşte, bu koda dayalı olarak zaman aşımı simgeleri oluşturmak için kullanabileceğiniz bir işlev.

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 projelerinde async/await kullanabilirsiniz, sadece the async targeting pack kullanın. Benim için harika çalışıyor!

Answer 3

Hala yukarıda kabul edilen yanıt çok benzer Microsoft.Bcl.Async bir uzantısı yöntemidir CancelAfter() kullanabilirsiniz.

/// <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); 
    }