Ufdjrw

I have 3 classes:

• Sensor: reads data continously from serial port and parses it. When data is parsed, adds it to blockingCollection




• DataProcessing: Gets the data from blockingCollecion and process it.




• DisplayDataForm: Displays processed data

How can I make sure, DataProcessing runs continously but not blocking and when new data arrives and its processed is displayed in the form?

class Sensor

 public BlockingCollection<double[]> _bufferTimeSeriesData;

 public void serialPort_DataReceived(object sender, System.IO.Ports.SerialDataReceivedEventArgs e)
 
 byte[] buffer = new byte[_serialPort1.BytesToRead];
 lock (buffer)
 
 _serialPort1.Read(buffer, 0, buffer.Length);

 double[] samplesAtTimeT;
 for (int i = 0; i < buffer.Length; i++)
 
 samplesAtTimeT = _BinaryStreamConverter.interpretBinaryStream(buffer[i]);
 if (samplesAtTimeT != null)
 _bufferTimeSeriesData.Add(samplesAtTimeT); //This is the BlockingCollection
 
 _bufferTimeSeriesData.CompleteAdding();
 
 


class DataProcessing

 public void ProcessData()
 
 Task.Run(() =>
 
 while (Globals.Sensor._bufferTimeSeriesData.IsCompleted)
 
 double[] samplesAtTimeT = Globals.Sensor._bufferTimeSeriesData.Take();

 //Process data

 // writes data to file (is it correct to do it here?)

 // Send processed data to form to plot in a chart. HOW??

 
 
 


class DisplayForm:Form

 public void DisplayDataInForm(double[] samples)
 
 chartCh1.Series["Signal"].Points.Add(samples[1]);
 chartCh2.Series["Signal"].Points.Add(samples[2]);

 while (chartCh1.Series["Signal"].Points.Count > 1000)
 
 chartCh1.Series["Signal"].Points.Remove(chartCh1.Series["Signal"].Points.First());
 chartCh2.Series["Signal"].Points.Remove(chartCh2.Series["Signal"].Points.First());