diff options
author | Determinant <[email protected]> | 2018-11-20 20:43:57 -0500 |
---|---|---|
committer | Determinant <[email protected]> | 2018-11-20 20:43:57 -0500 |
commit | d2fe5eb74bdf40afc5cacd052f40b56aa3e57eaf (patch) | |
tree | 30e042013d87d10cf9e0db95fd9398878b305915 /test/test_queue.cpp | |
parent | 60c4af2602e18933f2b795500f44c6613c852f45 (diff) |
refactor libuv wrapper classes
Diffstat (limited to 'test/test_queue.cpp')
-rw-r--r-- | test/test_queue.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/test/test_queue.cpp b/test/test_queue.cpp index 41c6f88..7b06951 100644 --- a/test/test_queue.cpp +++ b/test/test_queue.cpp @@ -4,6 +4,8 @@ #include "salticidae/event.h" +using salticidae::TimerEvent; + void test_mpsc(int nproducers = 16, int nops = 100000, size_t burst_size = 128) { size_t total = nproducers * nops; salticidae::EventContext ec; @@ -23,10 +25,10 @@ void test_mpsc(int nproducers = 16, int nops = 100000, size_t burst_size = 128) }); std::vector<std::thread> producers; std::thread consumer([&collected, total, &ec]() { - salticidae::Event timer(ec, -1, [&ec, &collected, total](int, short) { + TimerEvent timer(ec, [&ec, &collected, total](TimerEvent &) { if (collected.load() == total) ec.stop(); }); - timer.add_with_timeout(1, 0); + timer.add(1); ec.dispatch(); }); for (int i = 0; i < nproducers; i++) |