From f8558238bf89d88fa90e8d70a74c6d641d9a72d3 Mon Sep 17 00:00:00 2001 From: Bruno BELANYI Date: Fri, 25 Mar 2022 10:47:14 +0100 Subject: [PATCH] kraken: don't use a thread for reading input --- src/kraken.cc | 20 ++++++++------------ 1 file changed, 8 insertions(+), 12 deletions(-) diff --git a/src/kraken.cc b/src/kraken.cc index 995dd76..27826e4 100644 --- a/src/kraken.cc +++ b/src/kraken.cc @@ -43,17 +43,13 @@ int main(int argc, char** argv) { } }); - auto reader = std::jthread([&]() { - for (std::string line; std::getline(std::cin, line);) { - auto const order = kraken::parse::parse_single_order( - kraken::csv::read_csv_line(line)); - while (!pending_orders.push(order)) { - // FIXME: busy wait - } + for (std::string line; std::getline(std::cin, line);) { + auto const order = kraken::parse::parse_single_order( + kraken::csv::read_csv_line(line)); + while (!pending_orders.push(order)) { + // FIXME: busy wait } - // EOF, bring process orders and bring - writer.request_stop(); - }); - - reader.join(); + } + // EOF, process orders and bring down + writer.request_stop(); }