Concurrency

Conflate for a Slow Consumer

Difficulty

Asked at Hudson River Trading

Read the problem, hints and solution here. The editor needs a bigger screen: open this page on a laptop to write and run your code.

This problem is only available to subscribers.

Language: C++23Conflator

#include <cstddef>
#include <deque>
#include <optional>
#include <utility>
#include <vector>

// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
// ...
class Conflator {
public:
    explicit Conflator(int instrument_count)
        : latest_(static_cast<std::size_t>(instrument_count), 0) {}

    void publish(int instrument, long long value) {
        // ...
        (void)instrument;
        (void)value;
    }

    std::optional<std::pair<int, long long>> consume() {
        // ...
        return std::nullopt;
    }

    std::size_t pending() const {
        // ...
        return 0;
    }

private:
    std::vector<long long> latest_;
    std::deque<int> order_;
};

Unlock to runUpgrade

Unlock the problem to run it against the tests.

Conflate for a Slow Consumer

xxxxxxxx

xxxxxxxxxxx