У меня есть многопоточное приложение, в котором один рыночный данные обновления производителя для нескольких инструментов для нескольких инструментов, и несколько потребительских потоков прочитают эти данные для вычисления спотовых цен на основе таких стратегий, как Spot = (bid + ask) / 2 < / code>. или spot = bid * bid_qty /ask * ask_qty < /code> < /p>
Структура прибора выглядит следующим образом: < /p>
#include
#include
#include
#include
#include
#include
struct Instrument {
std::string isin;
double bid;
double ask;
double bid_qty;
double ask_qty;
Instrument(const std::string& id)
: isin(id), bid(0), ask(0), bid_qty(0), ask_qty(0) {}
};
std::unordered_map instruments;
void producer() {
while (true) {
for (auto& [isin, inst] : instruments) {
inst->bid = 100.0 + rand() % 10;
inst->ask = 110.0 + rand() % 10;
inst->bid_qty = rand() % 100;
inst->ask_qty = rand() % 100;
}
std::this_thread::sleep_for(std::chrono::milliseconds(10));
}
}
void consumer(int id) {
while (true) {
for (const auto& [isin, inst] : instruments) {
double spot = (inst->bid + inst->ask) / 2;
std::cout
Подробнее здесь: https://stackoverflow.com/questions/796 ... oducer-and
