Потребители очереди и состояние гонки

Question

У меня есть приложение, которое будет постоянно получать цены на акции из внешней системы.

Цены будут определяться запасом.

По мере поступления цен они будут отправлены в очередь блокировки.

Будет пул потоков, который будет потреблять и обрабатывать из этой очереди и помещать цены в кеш (хэш карты id и цены).

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

Есть ли способ обойти этот сценарий?

Как я могу убедиться, что последнее обработано последним?

Answer 1

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

В качестве альтернативы вы можете разделить свой фондовый юниверс по потокам, что означает, что обновления для данного запаса всегда обрабатываются одним и тем же потоком.