MCPcopy Create free account
hub / github.com/David-Haim/concurrencpp / insert

Function insert

test/source/tests/async_lock_tests.cpp:30–40  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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();

Callers 1

Calls 1

lockMethod · 0.80

Tested by

no test coverage detected