An Experiment Collects Samples
What a Test looks like
class MP { // Message Passing int x_; int y_; public: typedef std::tuple<int> Result; MP(); void t1(); void t2(Result& read); auto actions() { return std::make_tuple([this]() { t1(); }, [this](Result& result) { t2(result); }); } };
The Test interface must provide a Result type, and an actions() member that will produce a tuple of functions to run which either take no arguments or a reference to a result.
The test being defined here is the basic Message Passing litmus test.
MP::MP() : x_(0), y_(0) {} void MP::t1() { x_ = 1; y_ = 1; } void MP::t2(Result& read) { while (!y) { } std::get<0>(read) = x_; }
Two variables are initialized to 0. One thread stores 1 to x first, then to 1 to y. The other thread loops until it reads a non-zero in y, and then reads x. The value in x is the message being passed between threads.
In an actual test, the variables would be atomics, specifiying load and store strength, and the variables might have constraints on layout to help sharing cache line updates.
An Experiment
void Experiment::run(size_t count) { using Actions = decltype(std::declval<Test>().actions()); auto getters = tupleutil::tuple_getters<Actions>(); for (size_t i = 0; i < count; ++i) { Sample<Test> sample; sample.run(getters); resultMap_[sample.result_]++; std::next_permutation(getters.begin(), getters.end()); } }
tupleutil::tuple_getters returns an array of getters each of which returns a std::variant<Types…> with the same parameter pack as the tuple.
Sample runs all of the actions in a batch that locks them behind a spingate, and collects the results for each action.
template <class Test> class Sample { public: Batch batch_; Test test_; typename Test::Result result_; template <typename V, size_t I> void run(std::array<V, I> const& getters) { auto const& actions = test_.actions(); add(actions, getters); batch_.run(); } };
Add is a templated member function that loops over the array, uses the getter to pull a function out of the tuple of actions and visits that with a lambda that will add either the function with no arguments, or that function with a reference to the results, to the batch.
template <typename Tuple, typename Variant, size_t I> void add(Tuple const& actions, std::array<Variant, I> const& getters) { auto adder = [this](auto&& f) { using F = std::remove_cv_t<std::remove_reference_t<decltype(f)>>; if constexpr (std::is_invocable_v<F>) { batch_.add(f); } else { batch_.add(f, std::ref(result_)); } }; for (auto&& get_n : getters) { std::visit(adder, get_n(actions)); } return; }
I am a bit dissatisfied with the else case not being constexpr if followed by a static assert, but getting the condition right didn’t work the obvious way, so I punted. There will be a compiler error if f(result_) can’t actually be called by the batch.
Batch recapped:
template <class Function, class... Args> void Batch::add(Function&& f, Args&&... args) { workers_.emplace_back([ this, f = std::forward<Function>(f), args... ]() { gate_.wait(); f(args...); }); }
Batch has a spingate and runs all of the functions that are added sitting behind it. The run() function opens the gate and joins all the worker threads.
void Batch::run() { gate_.open(); for (auto& thr : workers_) { thr.join(); } }
Leave a Reply