adam/Alepha
1
0
Fork 0
forked from Alepha/Alepha
Code Pull Requests Activity

Switch the dead drop to use a circular buffer.

Browse Source
This commit is contained in:
ADAM David Alan Martin
2024-05-24 13:28:16 -04:00
parent 2442ddac2b
commit 4045c30021
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Atomic/DeadDrop.h
View File

@ -8,6 +8,8 @@ static_assert( __cplusplus > 2020'99 );
#include <queue> #include <queue>
#include <boost/circular_buffer.hpp>
#include <Alepha/Thread.h> #include <Alepha/Thread.h>
namespace Alepha::Hydrogen::Atomic ::detail:: DeadDrop_m namespace Alepha::Hydrogen::Atomic ::detail:: DeadDrop_m
@ -33,7 +35,7 @@ namespace Alepha::Hydrogen::Atomic ::detail:: DeadDrop_m
Item original; Item original;
Item *active= &original; Item *active= &original;
std::queue< Item * > next; boost::circular_buffer< Item * > next{ 2 };
Box *companion= nullptr; Box *companion= nullptr;
@ -56,7 +58,7 @@ namespace Alepha::Hydrogen::Atomic ::detail:: DeadDrop_m
std::unique_lock lock{ *access }; std::unique_lock lock{ *access };
ready.wait( lock, [&]{ return not next.empty(); } ); ready.wait( lock, [&]{ return not next.empty(); } );
active= next.front(); active= next.front();
next.pop(); next.pop_front();
} }
assert( active ); assert( active );
return *active; return *active;
@ -66,7 +68,7 @@ namespace Alepha::Hydrogen::Atomic ::detail:: DeadDrop_m
releaseBox() releaseBox()
{ {
std::unique_lock lock{ *access }; std::unique_lock lock{ *access };
companion->next.push( active ); companion->next.push_back( active );
active= nullptr; active= nullptr;
companion->ready.notify_one(); companion->ready.notify_one();
} }