C#

<br />
                lock (this)<br />
                {<br />
                    if (RUNNING)<br />
                    {<br />
                        RemovePortHandlerRAW.Write(serialPort.ReadExisting());<br />
                        RemovePortHandlerRAW.Flush();<br />
                        /*<br />
                        ThreadPool.QueueUserWorkItem(new WaitCallback(onDataReceived));<br />
                        currentRunningThreads++;*/<br />
                    }<br />
                }<br />

<code>
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.IO;
using System.IO.Ports;

namespace SerialTest
{
    class SerialReceiver
    {
        private System.Threading.ManualResetEvent m_Closed = new System.Threading.ManualResetEvent(false);
	    private System.IO.Ports.SerialPort m_Port = null;
	    private Thread m_Thread = null;

	    public SerialReceiver()
	    {	
		    this.m_Closed = new ManualResetEvent(false);
		    this.m_thread = new Thread(new ThreadStart(this.ThreadEntry));
		    this.m_thread.Start();
	    }

	    public ~SerialReceiver()
	    {
		    // make sure that the thread can end now
		    Close();
	    }

	    public void Close()
	    {
 		    this.m_Closed.Set();
	    }

        // thread entry point.
	    public void ThreadEntry()
	    {
		    this.m_Port  = new System.IO.Ports.SerialPort("COM1");
            this.m_Port.ReceivedBytesThreshold=1;

            SerialDataReceivedEventHandler receivedHandler = new SerialDataReceivedEventHandler(Port_DataReceived);
		    // register event handler
            this.m_Port.DataReceived += receivedHandler;

		    // start listening
		    this.m_Port.Open();

		    // wait for the closed event
		    this.m_Closed.WaitOne();

		    // deregister event handler
		    this.m_Port.OnDataReceived+= receivedHandler;   		
	    }

        void Port_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            // get a buffer for all the available data
            byte[] data = new byte[this.m_Port.BytesToRead];
            // read the data
            this.m_Port.Read(data,this.m_Port.BytesToRead);

            // dispatch the data...
            foreach(byte b in data)
            {
                //start your data handler thread here...
            }

        }

    }
}</code>