Lines Matching refs:r1
82 namespace r1 {
107 r1::enqueue(*task_handle_accessor::release(th), ctx, ta); in enqueue_impl()
117 friend struct r1::task_arena_impl;
118 friend void r1::observe(d1::task_scheduler_observer&, bool);
135 std::atomic<r1::arena*> my_arena;
136 static_assert(sizeof(std::atomic<r1::arena*>) == sizeof(r1::arena*),
204 r1::isolate_within_arena(func, /*isolation*/ 0); in isolate_impl()
233 …r1::enqueue(*alloc.new_object<enqueue_task<typename std::decay<F>::type>>(std::forward<F>(f), allo… in enqueue_impl()
251 r1::execute(*this, func); in execute_impl()
297 if (r1::attach(*this)) { in task_arena()
309 atomic_do_once([this]{ r1::initialize(*this); }, my_initialization_state); in initialize()
321 r1::initialize(*this);
338 r1::initialize(*this);
349 if ( !r1::attach(*this) ) { in initialize()
350 r1::initialize(*this); in initialize()
365 r1::terminate(*this); in terminate()
425 r1::wait(*this); in debug_wait_until_empty()
432 return (my_max_concurrency > 1) ? my_max_concurrency : r1::max_concurrency(this); in max_concurrency()
438 r1::submit(t, ctx, ta.my_arena.load(std::memory_order_relaxed), as_critical ? 1 : 0); in submit()
451 slot_id idx = r1::execution_slot(nullptr); in current_thread_index()
463 return r1::max_concurrency(nullptr); in max_concurrency()
475 using r1::submit;