Получение IOException с NetworkStream.BeginRead()

Question

При выполнении этого кода:

private async void StartChat(Object obj) 
{ 
    TcpClient me = (TcpClient)obj; 
    UpdateChatBox("Attempting read from server."); 
    myBuffer = new byte[BUFFER_SIZE]; 

    while (true) 
    { 
     var myStream = me.GetStream(); 
     myStream.BeginRead(myBuffer, 0, BUFFER_SIZE, new AsyncCallback(UpdateChatBoxAsync), myStream); 

     if (messageToSend) 
     { 
      await myStream.WriteAsync(myMessage, 0, myMessage.Length); 
     }     
    } 
} 

Я получаю следующее исключение ввода-вывода из BeginRead:

Невозможно прочитать данные из транспортного соединения: Операция сокета не может быть выполнена, потому что в системе недостаточно места для буфера или потому, что очередь заполнена.

Вот метод обратного вызова для BeginRead:

private void UpdateChatBoxAsync(IAsyncResult result) 
{ 
    var stream = result.AsyncState as NetworkStream; 
    int bytesRead = stream.EndRead(result); 

    if (bytesRead > 0) 
    { 
     String newMessage = NetworkUtils.GetString(myBuffer); 
     UpdateChatBox(newMessage); 
    } 
} 

Может кто-то пожалуйста, пролить некоторый свет, по той причине, что это исключение, которого воспитали? Я попытался воссоздать буфер каждый раз в начале цикла while, но пока это не улучшало исключение, я не получал сообщения с сервера.

Я также попытался сбросить myBuffer на пустой массив в конце UpdateChatBoxAsync, это тоже не сработало.

Любая помощь будет оценена по достоинству.

Answer 1

Вы запуская бесконечный цикл без дросселирования. Вы выдаете асинхронные запросы чтения так же быстро, как это может сделать CPU. Это создает неограниченное количество выдающихся операций.

Предполагается, что вы прочитаете следующее, когда последний из них завершен (чаще всего выполняется с обратного вызова).

просто добавив

if (myStream.DataAvailable) 

избежать чтения, но все еще сгореть одно ядро ​​процессора. Это всего лишь смягчение одного из симптомов. Исправьте основную причину.

Кажется, вы не должны делать async IO вообще, потому что у вас нет проблем с блокировкой. Вы блокируете поток и сжигаете 100% ядра. Если это приемлемо, даже не беспокойтесь о async IO.

Или, используйте await ReadAsync.

Answer 2

Я нашел свое решение.

Перед пробуя BeginRead я проверяю, если поток имеет какие-либо данные, доступные с помощью NetworkStream.DataAvailable или в моем случае myStream.DataAvailable

Таким образом, новый рабочий блок кода выглядит

if (myStream.DataAvailable){ 
    myStream.BeginRead(myBuffer, 0, BUFFER_SIZE, new AsyncCallback(UpdateChatBoxAsync), myStream); 
}