MCPcopy Create free account
hub / github.com/NVIDIA/stdexec / get_remote_queue

Function get_remote_queue

include/exec/static_thread_pool.hpp:502–517  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

500 }
501
502 auto get_remote_queue() noexcept -> remote_queue*
503 {
504 remote_queue* queue = remotes_.get();
505 std::size_t index = 0;
506 for (std::thread& t: threads_)
507 {
508 if (t.get_id() == queue->id_)
509 {
510 queue->index_ = index;
511 break;
512 }
513
514 ++index;
515 }
516 return queue;
517 }
518
519 void request_stop() noexcept;
520

Callers 4

get_scheduler_on_threadFunction · 0.85
enqueueMethod · 0.85
bulk_enqueueMethod · 0.85

Calls 2

get_idMethod · 0.80
getMethod · 0.45

Tested by

no test coverage detected