feedc0de/boost_unordered
1
0
Fork 0
forked from boostorg/unordered
Code Pull Requests Activity

micro-optimized reserve_available

Browse Source
This commit is contained in:
joaquintides
2023-03-14 15:14:09 +01:00
committed by Christian Mazakas
parent 06535e518e
commit 5e225fe46c
1 changed files with 1 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
include/boost/unordered/detail/foa/concurrent_table.hpp
View File

@ -564,7 +564,7 @@ private:
reserve_available(concurrent_table& x_):x{x_} reserve_available(concurrent_table& x_):x{x_}
{ {
do{ do{
available=x.available.load(std::memory_order_acquire); available=x.available.load(std::memory_order_relaxed);
}while( }while(
available&&!x.available.compare_exchange_weak(available,available-1)); available&&!x.available.compare_exchange_weak(available,available-1));
} }
@ -597,12 +597,8 @@ private:
boost::uint32_t counter=insert_counter(pos0); boost::uint32_t counter=insert_counter(pos0);
if(unprotected_visit(k,pos0,hash,f))return 0; if(unprotected_visit(k,pos0,hash,f))return 0;
#if 1
reserve_available ra(*this); reserve_available ra(*this);
if(BOOST_LIKELY(ra.succeeded())){ if(BOOST_LIKELY(ra.succeeded())){
#else
if(BOOST_LIKELY(this->available!=0)){
#endif
for(prober pb(pos0);;pb.next(this->arrays.groups_size_mask)){ for(prober pb(pos0);;pb.next(this->arrays.groups_size_mask)){
auto pos=pb.get(); auto pos=pb.get();
auto pg=this->arrays.groups+pos; auto pg=this->arrays.groups+pos;
@ -620,11 +616,7 @@ private:
} }
auto p=this->arrays.elements+pos*N+n; auto p=this->arrays.elements+pos*N+n;
this->construct_element(p,std::forward<Args>(args)...); this->construct_element(p,std::forward<Args>(args)...);
#if 1
ra.commit(); ra.commit();
#else
--(this->available);
#endif
f(type_policy::value_from(*p)); f(type_policy::value_from(*p));
return 1; return 1;
} }