|
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163 |
-
- #include <chrono>
- #include <iostream>
- #include <string>
- #include <conio.h>
- #include <thread>
-
- #include "librf.h"
-
- using namespace resumef;
-
- std::thread async_set_event(const event_t & e, std::chrono::milliseconds dt)
- {
- return std::thread([=]
- {
- std::this_thread::sleep_for(dt);
- e.signal();
- });
- }
-
-
- future_vt resumable_wait_event(const event_t & e)
- {
- using namespace std::chrono;
-
- if (co_await e.wait() == false)
- std::cout << "time out!" << std::endl;
- else
- std::cout << "event signal!" << std::endl;
- }
-
- void test_wait_one()
- {
- using namespace std::chrono;
-
- {
- event_t evt;
- go resumable_wait_event(evt);
- auto tt = async_set_event(evt, 1000ms);
- this_scheduler()->run_until_notask();
-
- tt.join();
- }
- {
- event_t evt2(1);
- go[&]() -> future_vt
- {
- (void)co_await evt2.wait();
- std::cout << "event signal on 1!" << std::endl;
- };
- go[&]() -> future_vt
- {
- (void)co_await evt2.wait();
- std::cout << "event signal on 2!" << std::endl;
- };
- std::cout << std::this_thread::get_id() << std::endl;
- auto tt = async_set_event(evt2, 1000ms);
-
- this_scheduler()->run_until_notask();
-
- tt.join();
- }
- }
-
- void test_wait_any()
- {
- using namespace std::chrono;
-
- event_t evts[8];
-
- go[&]() -> future_vt
- {
- for (int i = 0; i < _countof(evts); ++i)
- {
- intptr_t idx = co_await event_t::wait_any(evts);
- std::cout << "event " << idx << " signal!" << std::endl;
- }
- };
-
- std::vector<std::thread> vtt;
-
- srand((int)time(nullptr));
- for (auto & e : evts)
- {
- vtt.emplace_back(async_set_event(e, 1ms * (500 + rand() % 1000)));
- }
-
- this_scheduler()->run_until_notask();
-
- for (auto & tt : vtt)
- tt.join();
- }
-
- void test_wait_all()
- {
- using namespace std::chrono;
-
- event_t evts[8];
-
- go[&]() -> future_vt
- {
- if (co_await event_t::wait_all(evts))
- std::cout << "all event signal!" << std::endl;
- else
- std::cout << "time out!" << std::endl;
- };
-
- std::vector<std::thread> vtt;
-
- srand((int)time(nullptr));
- for (auto & e : evts)
- {
- vtt.emplace_back(async_set_event(e, 1ms * (500 + rand() % 1000)));
- }
-
- this_scheduler()->run_until_notask();
-
- for (auto & tt : vtt)
- tt.join();
- }
-
- void test_wait_all_timeout()
- {
- using namespace std::chrono;
-
- event_t evts[8];
-
- go[&]() -> future_vt
- {
- if (co_await event_t::wait_all_for(1000ms, evts))
- std::cout << "all event signal!" << std::endl;
- else
- std::cout << "time out!" << std::endl;
- };
-
- std::vector<std::thread> vtt;
-
- srand((int)time(nullptr));
- for (auto & e : evts)
- {
- vtt.emplace_back(async_set_event(e, 1ms * (500 + rand() % 1000)));
- }
-
- this_scheduler()->run_until_notask();
-
- for (auto & tt : vtt)
- tt.join();
- }
-
- void resumable_main_event()
- {
- test_wait_one();
- std::cout << std::endl;
-
- test_wait_any();
- std::cout << std::endl;
-
- test_wait_all();
- std::cout << std::endl;
-
- test_wait_all_timeout();
- std::cout << std::endl;
- }
|