这是2011年做的⼀个项⽬，数据由专业的仪器采集，单台仪器最⾼可能达到256K的采样频率和32通道同时采集和存储，⽀持多台同时采集。数据过来之后，或实时显⽰波形，或进算法计算模块，算法的输出也会同时实时显⽰。因此，需要极快速的数据处理功能。 ⼦系统关系图如下：
使⽤⼀般的轮询是肯定达不到速度的要求了，于是决定使⽤事件触发的⽅式传递和处理数据。
低通滤波器设计
1. 数据类EntityData.cs
namespace DHapp.Entities
{
/**
* Data Changed Event
*/
public class DataChangedEventArgs : EventArgs
{
public int index;
public double currentValue;
public double[] series;
public DataChangedEventArgs(int index,
double currentValue, double [] series)
{
this.index = index;
this.currentValue = currentValue;
this.series = series;
}
} //End of DataChangedEventArgs
/**
* Data Entity Data Structure
led驱动电路*/
public class EntityData
{
//lock-free status
public static int IDEL = 0;
public static int BUSY = 1;
//data source type
public static int TimeStamps = 0;
public static int TimeSeries = 1;
public static int Spectrums = 2;
//data-change event dispatching
//data-change event dispatching
public event EventHandler<DataChangedEventArgs> EventDataChanged;
//data source information
public int DataType = TimeSeries;
public int Index = 0;
public string Name = "A";
//data
public double current = 0;
面膜仪
public double [] series = null;
//clean data series
public void Clear() { series = null; }
//fire data changed event
public void FireDataChangedEvent()
{
if (EventDataChanged != null)
EventDataChanged(this,
new DataChangedEventArgs(Index, current, series));
}
//receive a copy of signal data
public void Set(double value, double [] signals)
{
current = value;
series = signals;
/
/ FireDataChangedEvent();
}
//data copy
public void Copy(double[] source) { Copy(source, ref series); }
public static void Copy(double[] source, ref double[] destination) {
int size = source.Length;
if (destination == null ||
destination.Length != size) destination = new double[size];
Array.Copy(source, destination, size);
}
轴承装配机
} //End of EntityData
}
2. 信号输⼊模块基类EntitySensor.cs
namespace DHapp.Entities
{
public abstract class EntitySensor
{
public List<EntityData> dataSource = new List<EntityData>();
public void Clear() { dataSource.Clear(); }
//interfaces
public abstract void Start();
public abstract void Stop ();
} //End of EntitySensor
}
3. 计算处理类基类EntityAlgorithm.cs
* Abstract Signal Processing Algorithm
*/
public abstract class EntityAlgorithm
{
public List<EntityData> dataSource = new List<EntityData>();
public List<EntityData> outputData = new List<EntityData>();
//data source index and dataSource list position reference Dictionary<int, int> sourceIndex = new Dictionary<int, int>();
int lastSourceIndex = 0;
//clear data sources and indexes
public void Clear()
{
dataSource.Clear ();
sourceIndex.Clear();
}
//link data source
public void LinkDataSource(EntityData data)
汽车尾气抽排系统{
int index = data.Index;
if (sourceIndex.ContainsKey(index))
{
//replace existing data source link
int k = sourceIndex[index];
dataSource[k] = data;
}
else
{
//new data source
lastSourceIndex = index;
sourceIndex.Add(index, dataSource.Count);
dataSource.Add(data);
}
}
//data source updated - refresh display
public void UpdatedDataSource(int index)
{
if (lastSourceIndex == index)
Refresh();
}
//interfaces
public abstract bool VerifyDataSourceType(ref string message);
public abstract void Initialization();
public abstract void Refresh();
public abstract void Start();
public abstract void Stop();
}
}
4. 显⽰类基类EntityDisplay.cs
* Abstract Display Device
*/
public abstract class EntityDisplay
{
public List<EntityData> dataSource = new List<EntityData>();
/
/data source index and dataSource list position reference Dictionary<int, int> sourceIndex = new Dictionary<int, int>();
int lastSourceIndex = 0;
//clear data sources and indexes
public void Clear()
{
dataSource.Clear ();
sourceIndex.Clear();
}
//link data source
public void LinkDataSource(EntityData data)
{
int index = data.Index;
if (sourceIndex.ContainsKey(index))
{
//replace existing data source link
int k = sourceIndex[index];
dataSource[k] = data;
}
else
{
//new data source
lastSourceIndex = index;
sourceIndex.Add(index, dataSource.Count);
dataSource.Add(data);
}
}
//data source updated - refresh display
public void UpdatedDataSource(int index)
{
if (lastSourceIndex == index)
Refresh();
}
//interfaces
public abstract bool VerifyDataSourceType(ref string message);
public abstract void Initialization();
public abstract void Refresh();
public abstract void Start();
public abstract void Stop();
}
}
5. 核⼼任务类 TaskCenter.cs
各个模块在这⾥被连接起来
namespace DHapp.Tasks
{
public class TaskCenter
{
public List<EntityData> dataSources;
public List<EntityData> dataSources;
public List<EntityAlgorithm> algorithms;
public List<EntityDisplay> charts;
bool started = false;
/**
* Constructor
*/
public TaskCenter()
{
dataSources = new List<EntityData>();
algorithms = new List<EntityAlgorithm>();
charts = new List<EntityDisplay>();
}
/**
* Start | Stop
*/
public void Start() { started = true; }
public void Stop () { started = false; }
/**
* Link Data Sources
*/
public int LinkDataSource(EntityData source)
{
//set data source reference index
int index = dataSources.Count;
source.Index = index;
dataSources.Add(source);
//link data change event processor
source.EventDataChanged += new EventHandler<DataChangedEventArgs>(processDataChangedEvent);
return dataSources.Count;
耐高温润滑油
}
/**
* Link Algorithm with Output Data as Data Source
*/
public int LinkAlgorithm(List<int> sourceIndex,
List<EntityData> outputData,
EntityAlgorithm algorithm)
{
//link data source to algorithm
foreach (int index in sourceIndex)
algorithm.LinkDataSource(dataSources[index]);
/
/set output data from algorithm to data source
for(int i=0; i<outputData.Count; i++) LinkDataSource(outputData[i]);
//add algorithm
algorithms.Add(algorithm);
return dataSources.Count;
}
/**
* Link Display Device
*/
public void LinkDisplayDevice(List<int> sourceIndex, EntityDisplay chart)
{
/
/link data source to display device
foreach (int index in sourceIndex)
chart.LinkDataSource(dataSources[index]);
豫公网安备41160202000603
站长QQ:729038198
关于我们
投诉建议