Почему сети.C#

Место общения программистов C#
Anonymous
Почему сети.

Сообщение Anonymous »

У меня есть задача, которая должна постоянно читать из потока TCP и поместить данные в condurentqueue для обработки. Пройдя через функцию, я замечаю, что вызов readAsync не возвращается. Затем появляется окно приложения, пропуская оставшуюся часть петли. < /p>
private async Task ReceiveLoop()
{
byte[] buffer = new byte[1024];
while (_isConnected)
{
if(_stream != null && _stream.CanRead)
{
try
{
int bytesRead = await _stream.ReadAsync(buffer, 0, buffer.Length);
if (bytesRead > 0)
{
byte[] receivedData = new byte[bytesRead];
Buffer.BlockCopy(buffer, 0, receivedData, 0, bytesRead);
if(_receiveQueue != null)
{
_receiveQueue.Enqueue(receivedData);
}
}
}
catch (ObjectDisposedException ex)
{
// Log[Error] - ex
_isConnected = false;
}
catch(InvalidOperationException ex)
{
//Log[Warning] - ex
}
}
// Console.WriteLine("ReceiveLoop is alive");
}
}


Подробнее здесь: https://stackoverflow.com/questions/797 ... d-the-loop

Вернуться в «C#»