Как хранить данные в реальном времени

Question

Я разрабатываю приложение на фондовом рынке в виде окон с использованием .net framework 4.0. Я извлекаю тики из обмена в реальном времени. Я могу получать тики в режиме реального времени. В моем сценарии мне нужно создать поток, который будет писать в реальном времени фиды в общей коллекции & другой непрерывный фоновый поток будет извлекать его из коллекции & делает дальнейшую обработку. Для этого я использую комбинацию ConcurrentDictionary и ConcurrentQueue. Имя символа конатинов & Значение содержит ConcurrentQueue. Так оно и было реализовано. Check first answer

Это прекрасно работает, моя единственная забота - это задержка. Этот процесс вызывает задержку в 1 секунду, поскольку цены на акции должны колебаться в режиме реального времени. Может ли этот сценарий быть реализован какой-то другой логикой или я могу каким-то образом улучшить производительность ConcurrentDictionary или ConcurrentQueue, чтобы избежать задержек?

Answer 1

Вам действительно нужен параллельный словарь? Ваш словарь изменяется только тогда, когда вы находите новый символ. Если вам известны все символы заранее, вы можете создать обычный словарь, заполнить его очередью на символ, и это все - словарь никогда не изменится дальше этого.

Я не уверен, как работает поток обработки, - как он узнает, в какую очередь смотреть дальше? Перебирает ли он все очереди, чтобы узнать, есть ли еще данные? Возможно, вам нужно всего лишь один ConcurrentQueue, который проведет все события на фондовом рынке и разделит его на отдельные контейнеры в фоновом режиме (возможно, без синхронизации).

Answer 2

Почему бы вам не задать объект, содержащий идентификатор stmbol и соответствующую страницу, удалить его рабочими потоками (без назначения выделенного потока каждому идентификатору символа), а затем рабочий поток отправит страницу в правильная обработка в зависимости от идентификатора символа с помощью простого оператора case switch.

Таким образом, вам не нужно проверять наличие очереди для символа. У вас будет только одна потокобезопасная очередь типа И вы можете использовать ThreadPool для обработки!

рабочие потоки будут делать это:

IdPagePair pair = market.Dequeue(); 

if (pair.Id == 1) { Process1(pair.Page); } 

else 

if (pair.Id == 2) { Process2(pair.Page); } 

// etc...