タイムアウトのあるWriteAsync

Question

以下のようなタイムアウトのシンプルな非同期書き込みをコーディングし、非常に大きなバッファと小さなwaitTimeを指定すると、関数がTaskCanceledExceptionをスローすると考えます。しかし、これは起こりません。 WriteAsyncは、書き込みが完了するまで数秒間ブロックします。私は何が欠けていますか？ GUIスレッドから

public async void WriteWithTimeout(Stream os, byte[] buf, int waitMs) 
{ 
    CancellationTokenSource tokenSource = new CancellationTokenSource(waitMs); // cancel after waitMs milliseconds. 
    await os.WriteAsync(buf, 0, buf.Length, tokenSource.Token); 

    return; 
} 

コール：

try 
{ 
    WriteWithTimeout(response.OutputStream, buf100M, w1ms); 
} 
catch(OperationCanceledException e) 
{ 
    ConsoleWriteLine("Failed with exception: {0}", e.Message); 
}   

Answer 1

あなたは非同期ボイドをキャッチすることはできません。それはタスクを返さなければならず、あなたはそれを待たなければなりません。

public async Task WriteWithTimeout(Stream os, byte[] buf, int waitMs) 
{ 
    CancellationTokenSource tokenSource = new CancellationTokenSource(waitMs); // cancel after waitMs milliseconds. 
    await os.WriteAsync(buf, 0, buf.Length, tokenSource.Token); 

    return; 
} 

GUIコード

try 
{ 
    await WriteWithTimeout(response.OutputStream, buf100M, w1ms); 
} 
catch(OperationCanceledException e) 
{ 
    ConsoleWriteLine("Failed with exception: {0}", e.Message); 
} 

キャンセルはまだ起きていますが、単にそれを守りません。

更新：

os.WriteAsync(がちょうど舞台裏Task.Run(に裏打ちされただけで、同期完了であることが可能です。キャンセルトークンは既に実行中のTask.Run(をキャンセルしません。その場合、最善の方法は、Task.WhenAny(にキャンセルをラップし、無限に長いTask.Delay(経由でそこにトークンを渡すことです。

public async Task WriteWithTimeout(Stream os, byte[] buf, int waitMs) 
{ 
    CancellationTokenSource tokenSource = new CancellationTokenSource(waitMs); // cancel after waitMs milliseconds. 
    var task = os.WriteAsync(buf, 0, buf.Length, tokenSource.Token); 
    var waitedTask = await Task.WhenAny(task, Task.Delay(-1, token)); 
    await waitedTask; //Wait on the returned task to observe any exceptions. 
} 

---

^{1.あなたは}