Как безопасно поделиться обновленными рыночными данными (структурой удвоения) между потоками производителя и потребителе ⇐ Linux

[Anonymous]

У меня есть многопоточное приложение, в котором один рыночный данные обновления производителя для нескольких инструментов для нескольких инструментов, и несколько потребительских потоков прочитают эти данные для вычисления спотовых цен на основе таких стратегий, как 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