Все -Взаимодействие данных в реальном времени
У меня есть проект POC WPF, который работает от конца до конца. Приложение имитирует рыночные данные в реальном времени, публикуемые через библиотеку (Publisher), а мой клиент WPF - это Subscriber (имеет метод обработчика). Он использует пользовательские события для публикации данных.
Вопрос у меня есть это:
1) Я хочу осуществить Производитель Потребитель - поэтому мой обработчик не тянет данные в коллекцию непосредственно наблюдаемую.
2) Я точно знаю, как реализовать фрагменты Producer/Consumer C# (http://msdn.microsoft.com/en-us/library/hh228601.aspx), но хотел бы больше понять, как это будет соответствовать моей нынешней архитектуре. Вот диаграмма
3) Может ли кто-нибудь помочь мне с кодом подход, ссылки и т.д.
MainWindowViewModel.cs
public class MainWindow_VM : ViewModelBase
{
#region Properties
public myCommand SbmtCmd { get; set; }
public ObservableCollection<StockModel> stocks { get; set; }
#endregion
#region Fields
private readonly Dispatcher currentDispatcher;
#endregion
public MainWindow_VM()
{
SbmtCmd = new myCommand(mySbmtCmdExecute, myCanSbmtCmdExecute);
currentDispatcher = Dispatcher.CurrentDispatcher;
stocks = new ObservableCollection<StockModel>();
}
private void mySbmtCmdExecute(object parameter)
{
MarketDataProvider p = new MarketDataProvider();
p.OnMarketData += new EventHandler<MarketDataEventArgs>(handlermethod);
p.GenerateMarketData();
}
private bool myCanSbmtCmdExecute(object parameter)
{
return true;
}
// Subscriber method which will be called when the publisher raises an event
private void handlermethod(object sender, MarketDataEventArgs e)
{
foreach (Stock s in e.updatedstk)
{
StockModel sm = new StockModel();
sm.symbol = s.symbol;
sm.bidprice = s.bidprice;
sm.askprice = s.askprice;
sm.lastprice = s.lastprice;
currentDispatcher.Invoke(DispatcherPriority.Normal, (Action)delegate()
{
if (sm != null)
{
if (stocks.Any(x => x.symbol == sm.symbol))
{
var found = stocks.FirstOrDefault(x => x.symbol == sm.symbol);
int i = stocks.IndexOf(found);
stocks[i] = sm;
}
else
{
stocks.Add(sm);
}
}
});
}
}
}
Прочитать http://msdn.microsoft.com/en-us/data/gg577611 – JSJ
Спасибо Jodha - к сожалению, у меня есть ограничения на использование среды .Net 3.5 и, следовательно, необходимо решить эту проблему с использованием традиционных подходов C# – Patrick
Тогда вы также не можете использовать DataFlow. Он доступен только в .NET 4 и выше, в то время как активные версии доступны для 3.5 –