Home
last modified time | relevance | path

Searched refs:pred (Results 1 – 8 of 8) sorted by relevance

/oneTBB/include/oneapi/tbb/detail/
H A D_waitable_atomic.h37 d1::delegated_function<Predicate> pred(wakeup_condition); in adaptive_wait_on_address()
38 r1::wait_on_address(address, pred, context); in adaptive_wait_on_address()
65 d1::delegated_function<decltype(wakeup_condition)> pred(wakeup_condition); in wait()
67 r1::wait_on_address(this, pred, context); in wait()
H A D_flow_graph_cache_impl.h164 predecessor_type* pred = nullptr; in try_reserve() local
170 pred = &this->internal_pop(); in try_reserve()
171 reserved_src.store(pred, std::memory_order_relaxed); in try_reserve()
175 msg = pred->try_reserve( v ); in try_reserve()
180 register_successor( *pred, *this->my_owner ); in try_reserve()
184 this->add( *pred); in try_reserve()
/oneTBB/include/oneapi/tbb/
H A Dqueuing_mutex.h85 scoped_lock* pred = m.q_tail.exchange(this); in acquire() local
86 if (pred) { in acquire()
88 …__TBB_ASSERT(pred->m_next.load(std::memory_order_relaxed) == nullptr, "the predecessor has another… in acquire()
90 pred->m_next.store(this, std::memory_order_release); in acquire()
H A Dconcurrent_queue.h329 …(r1::concurrent_monitor* monitors, std::size_t monitor_tag, std::ptrdiff_t target, FuncType pred) { in internal_wait() argument
330 d1::delegated_function<FuncType> func(pred); in internal_wait()
563 auto pred = [&] { in internal_push()
572 internal_wait(my_monitors, cbq_slots_avail_tag, target, pred); in internal_push()
608 auto pred = [&] { in internal_pop()
617 internal_wait(my_monitors, cbq_items_avail_tag, target, pred); in internal_pop()
/oneTBB/test/common/
H A Dspin_barrier.h39 void SpinWaitWhile(Predicate pred) { in SpinWaitWhile() argument
41 while (pred()) { in SpinWaitWhile()
/oneTBB/src/tbb/
H A Darena.h165 bool try_clear_if(Pred&& pred) { in try_clear_if() argument
169 if (pred()) { in try_clear_if()
H A Dconcurrent_monitor.h259 bool wait(Pred&& pred, NodeType&& node) { in wait() argument
261 while (!guarded_call(std::forward<Pred>(pred), node)) { in wait()
/oneTBB/test/tbb/
H A Dtest_async_node.cpp739 for(auto& pred: preds) { in test_follows() local
740 pred.try_put(1); in test_follows()