У меня есть поток цен на 1000 различных акций, поступающих с биржи в мой код. Из-за очень большого количества обновлений мне нужно использовать многопоточную среду для обработки ценовых обновлений.
В простом мире у меня была бы одна очередь заданий и набор рабочих потоков, обрабатывающих очередь. Однако в реальном мире я не могу этого сделать, так как мне нужно поддерживать порядок времени обновлений для отдельных акций.
Простым решением было бы использование алгоритма хеширования, который выделял определенный запас одному и тому же потоку каждый раз, когда просматривалось обновление. К сожалению, если я это сделаю, это означает, что мне нужно понимать частоту обновления каждой из моих акций, чтобы убедиться, что мои потоки заняты (частоты обновления не постоянны для каждой акции). Если я не сделаю этого, некоторые темы могут быть насыщены, а другие бездействуют.
Кто-нибудь знает шаблон, который обслуживает эту проблему?