如何等待网络流读取数据?

// ...
netStream.BeginRead(buffer, offset, callback, state);
// ...

netStream.EndRead(ar);
netStreamManualResetEvent.Set();

那么你的代码

while (notDone)
{
    WaitHandle.WaitAny(new WaitHandle[] { queue1.HasData, queue2.HasData, netStreamManualResetEvent} );
    // ...
    if (netStream.DataAvailable)
    {
        // make the buffer from the AsyncState in the callback method available here
        // process buffer
    }
}

最简单的方法可能是使用一个额外的线程,该线程同步读取并将额外的数据放入额外的队列中。

或者,您可以使用异步IO,但这有点棘手,而且您仍然需要一些额外的队列。

尽管 Socket 有一个 Select() 方法(你可以从 NetworkStream )我不认为它以一种让你将其与其他类型的等待句柄混合使用的方式暴露了这一功能。

我发现,如果你打电话来 NetworkStream.Read 随着 size = 0 ,它实际上会阻止:

networkstream.Read(buffer, 0, 0);

这 documentation