I have a worker thread in my application that is responsible for three different things. Requests for two of the jobs turn up in Queues that I have written, the other job is activated when a request turns up on a Network stream. I would like my worker thread to wait when there is no work to be done. This is easy with the two Queues as they expose a ManualResetEvent that is set when they have items, however the NetworkStream does not seem to have this. The NetworkStream has been retrieved from a TcpClient.
What I am after is code that looks something like this:
while (notDone)
{
WaitHandle.WaitAny(new WaitHandle[] { queue1.HasData, queue2.HasData, netStream.HasData } );
// ...
if (netStream.DataAvailable)
{
netStream.Read(buffer, 0, 20);
// process buffer
}
}
Does anyone know a way to get a WaitHandle that is set when a NetworkStream has data?
You can use the async methods of the NetworkStream and set a ManualResetEvent in the EndReceive method.
inside the callback method
then your code
The simplest way is probably to use an additional thread which reads synchronously and puts extra data onto an extra queue.
Alternatively you could use asynchronous IO, but that's somewhat tricky - and you'd still need to have some additional queue.
Although
Socket
has aSelect()
method (and you can get at a socket from aNetworkStream
) I don't believe it exposes this functionality in a way which lets you mix it with other kinds of wait handles.