boost/fiber
2
0
Fork 0
mirror of https://github.com/boostorg/fiber.git synced 2026-02-12 12:02:54 +00:00
Code Issues Projects Releases Wiki Activity

efficent condition notify

Browse Source
This commit is contained in:
Oliver Kowalke
2013-01-28 18:13:33 +01:00
parent f35319daf2
commit 07c8a8ea98
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/condition.cpp
View File

@@ -45,17 +45,15 @@ condition::notify_one()
command expected = SLEEPING;
while ( ! cmd_.compare_exchange_strong( expected, NOTIFY_ONE) )
{
this_fiber::yield();
if ( this_fiber::is_fiberized() ) this_fiber::yield();
expected = SLEEPING;
}
unique_lock< detail::spinlock > lk( waiting_mtx_);
if ( ! waiting_.empty() )
{
detail::fiber_base::ptr_t f;
f.swap( waiting_.front() );
waiting_.front()->wake_up();
waiting_.pop_front();
f->wake_up();
}
}
@@ -80,7 +78,7 @@ condition::notify_all()
command expected = SLEEPING;
while ( SLEEPING != cmd_.compare_exchange_strong( expected, NOTIFY_ALL) )
{
this_fiber::yield();
if ( this_fiber::is_fiberized() ) this_fiber::yield();
expected = SLEEPING;
}