#include "util/scoped_timer.h"
#include "util/util.h"
#include "util/vector.h"
#include "util/trace.h"
#include <thread>
#include <atomic>
#include <iostream>
class test_scoped_eh : public event_handler {
std::atomic<bool> m_called = false;
public:
void operator()(event_handler_caller_t id) override {
m_caller_id = id;
m_called = true;
}
bool called() const { return m_called; }
};
static void worker_thread(unsigned tid) {
for (unsigned i = 0; i < 100; ++i) {
test_scoped_eh eh;
scoped_timer sc(1, &eh);
unsigned_vector v;
for (unsigned j = 0; j < (2 << 25); ++j) {
v.push_back(j);
if (eh.called()) {
break;
}
}
}
}
void tst_scoped_timer() {
std::cout << "sequential test\n";
worker_thread(0);
std::cout << "thread test\n";
unsigned num_threads = 3;
vector<std::thread> threads(num_threads);
for (unsigned i = 0; i < num_threads; ++i)
threads[i] = std::thread([&, i]() { worker_thread(i); });
for (auto& th : threads)
th.join();
}