Searched refs:my_slack (Results 1 – 2 of 2) sorted by relevance
135 std::atomic<int> my_slack; member in tbb::detail::r1::rml::private_server270 if( my_server.my_slack.load(std::memory_order_acquire)>=0 ) { in run()280 ++my_server.my_slack; in run()331 my_slack(0), in private_server()361 auto expected = my_slack.load(std::memory_order_relaxed); in try_insert_in_asleep_list()363 if (my_slack.compare_exchange_strong(expected, expected + 1)) { in try_insert_in_asleep_list()380 my_slack += additional_slack; in wake_some()386 int old = my_slack.load(std::memory_order_relaxed); in wake_some()389 } while (!my_slack.compare_exchange_strong(old, old - 1)); in wake_some()406 my_slack += allotted_slack; in wake_some()[all …]
371 std::atomic<int> my_slack; member in tbb::detail::rml::ipc_server409 if( my_slack.load(std::memory_order_acquire)>0 ) { in propagate_chain_reaction()567 if( my_server.my_slack>=0 ) { in run()832 my_slack = 0; in ipc_server()893 int k = ++my_slack; in try_insert_in_asleep_list()899 --my_slack; in try_insert_in_asleep_list()910 ++my_slack; in try_insert_in_asleep_list_forced()979 my_slack += additional_slack; in wake_some()1023 my_slack += additional_slack; in wake_one_forced()1063 my_slack+=delta; in adjust_job_count_estimate()[all …]