boostorg/unordered
1
0
Fork 1
mirror of https://github.com/boostorg/unordered.git synced 2025-07-31 11:57:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

made epoch mechanism oversubscription free

Browse Source
This commit is contained in:
joaquintides
2023-12-04 14:05:36 +01:00
parent 8bd1bcf5de
commit 86856f7e6b
1 changed files with 5 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -980,7 +980,7 @@ private:
struct group_shared_lock_guard struct group_shared_lock_guard
{ {
group_shared_lock_guard(epoch_type& e_):e{e_}{++e;} group_shared_lock_guard(epoch_type& e_):e{e_}{++e;}
~group_shared_lock_guard(){++e;} ~group_shared_lock_guard(){--e;}
epoch_type& e; epoch_type& e;
}; };
@ -989,7 +989,7 @@ private:
group_exclusive_lock_guard( group_exclusive_lock_guard(
epoch_type& e_,group_access::exclusive_lock_guard&& lck_): epoch_type& e_,group_access::exclusive_lock_guard&& lck_):
e{e_},lck{std::move(lck_)}{++e;} e{e_},lck{std::move(lck_)}{++e;}
~group_exclusive_lock_guard(){++e;} ~group_exclusive_lock_guard(){--e;}
epoch_type& e; epoch_type& e;
group_access::exclusive_lock_guard lck; group_access::exclusive_lock_guard lck;
@ -1820,16 +1820,12 @@ private:
mutable multimutex_type mutexes; mutable multimutex_type mutexes;
#if defined(BOOST_UNORDERED_LATCH_FREE) #if defined(BOOST_UNORDERED_LATCH_FREE)
static epoch_array epochs; mutable epoch_array epochs;
static void wait_for_epochs() void wait_for_epochs()
{ {
for(std::size_t i=0;i<epochs.size();++i){ for(std::size_t i=0;i<epochs.size();++i){
auto e=epochs[i].load(std::memory_order_acquire), while(epochs[i].load(std::memory_order_acquire)){}
e1=e|1u;
while(e==e1){
e=epochs[i].load(std::memory_order_acquire);
}
} }
} }
#endif #endif
@ -1838,12 +1834,6 @@ private:
template<typename T,typename H,typename P,typename A> template<typename T,typename H,typename P,typename A>
std::atomic<std::size_t> concurrent_table<T,H,P,A>::thread_counter={}; std::atomic<std::size_t> concurrent_table<T,H,P,A>::thread_counter={};
#if defined(BOOST_UNORDERED_LATCH_FREE)
template<typename T,typename H,typename P,typename A>
typename concurrent_table<T,H,P,A>::epoch_array
concurrent_table<T,H,P,A>::epochs={};
#endif
#if defined(BOOST_MSVC) #if defined(BOOST_MSVC)
#pragma warning(pop) /* C4714 */ #pragma warning(pop) /* C4714 */
#endif #endif