Отмена NetworkStream.ReadAsync с использованием TcpListener
Рассмотрим следующий упрощенный пример (готов к развертыванию в LinqPad, требуется повышенная учетная запись):
void Main()
{
Go();
Thread.Sleep(100000);
}
async void Go()
{
TcpListener listener = new TcpListener(IPAddress.Any, 6666);
try
{
cts.Token.Register(() => Console.WriteLine("Token was canceled"));
listener.Start();
using(TcpClient client = await listener.AcceptTcpClientAsync()
.ConfigureAwait(false))
using(var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5)))
{
var stream=client.GetStream();
var buffer=new byte[64];
try
{
var amtRead = await stream.ReadAsync(buffer,
0,
buffer.Length,
cts.Token);
Console.WriteLine("finished");
}
catch(TaskCanceledException)
{
Console.WriteLine("boom");
}
}
}
finally
{
listener.Stop();
}
}
Если я подключу клиент Telnet кlocalhost:6666
и сидеть без дела 5 секунд, почему я вижу "Токен был отменен но никогда не увижубум» (или же "законченный")?
Этот NetworkStream не будет уважать отмену?
Я могу обойти это с комбинациейTask.Delay()
а такжеTask.WhenAny
, но я'Я предпочел бы заставить это работать как ожидалось.
И наоборот, следующий пример отмены:
async void Go(CancellationToken ct)
{
using(var cts=new CancellationTokenSource(TimeSpan.FromSeconds(5)))
{
try
{
await Task.Delay(TimeSpan.FromSeconds(10),cts.Token)
.ConfigureAwait(false);
}
catch(TaskCanceledException)
{
Console.WriteLine("boom");
}
}
}
Принты "бум», как и ожидалось. Какие'происходит?