| 28 | } |
| 29 | |
| 30 | result<void> insert(executor_tag, |
| 31 | std::shared_ptr<executor> ex, |
| 32 | async_lock& lock, |
| 33 | std::vector<size_t>& vec, |
| 34 | size_t range_begin, |
| 35 | size_t range_end) { |
| 36 | for (size_t i = range_begin; i < range_end; i++) { |
| 37 | auto lk = co_await lock.lock(ex); |
| 38 | vec.emplace_back(i); |
| 39 | } |
| 40 | } |
| 41 | |
| 42 | result<std::pair<uintptr_t, uintptr_t>> get_thread_ids(async_lock& lock, std::shared_ptr<worker_thread_executor> executor) { |
| 43 | const auto before_id = concurrencpp::details::thread::get_current_virtual_id(); |
no test coverage detected