C#

/// <summary>
/// Read incoming bytes into a memory stream and notify
/// the separate proccessing thread
/// </summary>
/// <param name="packet"></param>
void comDriver_DataReceived(byte[] newData)
{
    lock (memory)
    {
        memory.Write(newData, 0, newData.Length);
        streamPosition += newData.Length;
    }

    DataWasReceived.Set();
}

/// <summary>
/// The data handler thread makes sure all incoming data is handled.
/// </summary>
public void DataHandleThread()
{
    byte[] b = null;
    byte[] leftOver = new byte[0];

    while (!stopReader)
    {
        // wait for notification from the com-driver
        DataWasReceived.WaitOne(-1, true);     // blocking line, according to ANTS
        DataWasReceived.Reset();

        //  do stuff
     }
 }