Wie kann ich ein timeout für eine Asynchrone Funktion, die nicht akzeptieren, eine Kündigung token?

Habe ich meine web-Anfragen behandelt, die von diesem code; 

Response = await Client.SendAsync(Message, HttpCompletionOption.ResponseHeadersRead, CToken);

Zurückgibt, die nach dem Antwort-Header gelesen werden, und bevor der Inhalt gelesen. Wenn ich diese Zeile um den Inhalt...

return await Response.Content.ReadAsStringAsync();

Ich möchte in der Lage sein, um es zu stoppen nach X Sekunden. Aber es nicht akzeptieren eine Stornierung token.

InformationsquelleAutor iguanaman | 2014-09-23
  1. 10

    Während Sie kann verlassen sich auf WithCancellation für die Wiederverwendung Zwecke, eine einfachere Lösung für ein timeout (was nicht werfen OperationCanceledException) wäre eine timeout-task mit Task.Delay und warten auf die erste Aufgabe zu vervollständigen mit Task.WhenAny:

    public static Task<TResult> WithTimeout<TResult>(this Task<TResult> task, TimeSpan timeout)
{
    var timeoutTask = Task.Delay(timeout).ContinueWith(_ => default(TResult), TaskContinuationOptions.ExecuteSynchronously);
    return Task.WhenAny(task, timeoutTask).Unwrap();
}

    Oder, wenn Sie wollen, um eine Ausnahme für den Fall gibt es ein timeout, anstatt einfach wieder den default-Wert (also null):

    public static async Task<TResult> WithTimeout<TResult>(this Task<TResult> task, TimeSpan timeout)
{
    if (task == await Task.WhenAny(task, Task.Delay(timeout)))
    {
        return await task;
    }
    throw new TimeoutException();
}

    Und die Verwendung wäre:

    var content = await Response.Content.ReadAsStringAsync().WithTimeout(TimeSpan.FromSeconds(1));
    • Während NedStoyanov die Antwort ist auch toll, das man speziell mit code zum behandeln ein timeout, anstatt nur so dass ein Widerruf. Ich fühle, dass dies eine Antwort auf die Frage besser.
    • Aber gibt es eine Garantie dafür, dass die Verzögerung der Aufgabe nicht geplant werden, bevor die Aufgabe? Es konnte nichts falsch mit der Aufgabe, aber die Aufgabenplanung konnte noch laufen die Verzögerung erst Recht (wenn die Aufgabe, die Kapazität gefüllt ist, die es zu wählen hat)?
    • ist nicht wirklich geplant, da es nicht wirklich "laufen". Es beginnt ein timer, der erscheint, nachdem das timeout und die Aufgabe abgeschlossen. Auch, die Aufgabe, die Sie bekommen, nicht "gestartet".. es ist schon heiss, also gibt es keine wirklichen sorgen (es sei denn, in sehr extremen Fällen).
    InformationsquelleAutor i3arnon
  2. 2

    Haben Sie einen Blick auf Wie kündige ich unkündbaren async-Operationen?. Wenn Sie wollen einfach nur die await zu beenden, während die Anfrage im hintergrund läuft, können Sie den Autor WithCancellation - Erweiterung-Methode. Hier wird es reproduziert aus dem Artikel:

    public static async Task<T> WithCancellation<T>( 
    this Task<T> task, CancellationToken cancellationToken) 
{ 
    var tcs = new TaskCompletionSource<bool>(); 
    using(cancellationToken.Register( 
                s => ((TaskCompletionSource<bool>)s).TrySetResult(true), tcs)) 
        if (task != await Task.WhenAny(task, tcs.Task)) 
            throw new OperationCanceledException(cancellationToken); 
    return await task; 
}

    Es im wesentlichen verbindet die ursprüngliche Aufgabe mit einer Aufgabe, die akzeptiert eine Kündigung token und wartet dann beide Aufgaben mit Task.WhenAny. So, wenn Sie kündigen, die CancellationToken die secodn Aufgabe storniert wird, aber das original hält. Solange Sie kümmern sich nicht darum, dass Sie diese Methode verwenden.

    Können Sie es verwenden, wie diese: 

    return await Response.Content.ReadAsStringAsync().WithCancellation(token);

    Update

    Können Sie auch versuchen, Sie zu entsorgen die Antwort als Teil der Widerrufsbelehrung. 

    token.Register(Reponse.Content.Dispose);
return await Response.Content.ReadAsStringAsync().WithCancellation(token);

    Nun so brechen Sie den token, der Content Objekt entsorgt werden.

    • Das ist toll vielen Dank, es gibt keine Möglichkeit zu stoppen ReadAsStringAsync in progress dann? Es ist eine großartige Lösung, aber im Idealfall möchte ich zum Abbruch des ReadAsStringAsync, wenn überhaupt möglich.
    • Sie können Thread.Abort wie in dieser Antwort stackoverflow.com/a/21715122/1239433, aber Sie können den Aufruf einer synchronen version der Funktion innerhalb Task.Run um es zu tun.
    • Traditionell Microsoft-APIs, stornieren Ihre I/O-Operationen, wenn die zugrunde liegende Griff ist geschlossen. Also, könnten Sie versuchen, die Entsorgung der Response.Content und/oder die Response wenn die cancel-token signalisiert wird.
    InformationsquelleAutor Ned Stoyanov
  3. 0

    Da gibt eine Aufgabe, können Sie Wait für die Aufgabe, die im wesentlichen äquivalent zu einem timeout:

    //grab the task object
var reader = response.Content.ReadAsStringAsync();

//so you're telling the reader to finish in X milliseconds
var timedOut = reader.Wait(X);  

if (timedOut)
{
    //handle timeouts
}
else
{
    return reader.Result;
}
    • Das macht es synchron, was nicht ideal ist.
    • Nur das Lesen Teil. Ob seine akzeptabel ist oder nicht, basierend auf, was ist wichtiger - zu können, timeout oder bleiben async, ohne die Kontrolle über den Prozess.
    InformationsquelleAutor Mrchief
Schreibe einen Kommentar