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

signal() added

Browse Source
This commit is contained in:
Oliver Kowalke
2015-09-10 19:52:08 +02:00
parent d3843efbe0
commit 4764c1184c
10 changed files with 94 additions and 95 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/context.cpp
View File

@@ -49,18 +49,16 @@ void
context::release() {
BOOST_ASSERT( is_terminated() );
std::vector< context * > waiting;
wait_queue_t tmp;
// get all waiting fibers
splk_.lock();
waiting.swap( wait_queue_);
tmp.swap( wait_queue_);
splk_.unlock();
// notify all waiting fibers
for ( context * f : waiting) {
BOOST_ASSERT( nullptr != f);
BOOST_ASSERT( ! f->is_terminated() );
f->set_ready();
for ( context * f : wait_queue_) {
do_signal( f);
}
// release fiber-specific-data
@@ -146,12 +144,11 @@ context::set_properties( fiber_properties * props) {
}
bool
context::do_wait_until_( std::chrono::steady_clock::time_point const& time_point,
detail::spinlock_lock & lk) {
context::do_wait_until_( std::chrono::steady_clock::time_point const& time_point) {
BOOST_ASSERT( nullptr != scheduler_);
BOOST_ASSERT( this == active_);
return scheduler_->wait_until( this, time_point, lk);
return scheduler_->wait_until( this, time_point);
}
void
@@ -170,14 +167,6 @@ context::do_schedule() {
scheduler_->run( this);
}
void
context::do_wait( detail::spinlock_lock & lk) {
BOOST_ASSERT( nullptr != scheduler_);
BOOST_ASSERT( this == active_);
scheduler_->wait( this, lk);
}
void
context::do_yield() {
BOOST_ASSERT( nullptr != scheduler_);
@@ -191,8 +180,26 @@ context::do_join( context * f) {
BOOST_ASSERT( nullptr != scheduler_);
BOOST_ASSERT( this == active_);
BOOST_ASSERT( nullptr != f);
BOOST_ASSERT( f != active_);
scheduler_->join( this, f);
if ( f->join( this) ) {
scheduler_->run( this);
}
}
void
context::do_signal( context * f) {
BOOST_ASSERT( nullptr != scheduler_);
BOOST_ASSERT( this == active_);
BOOST_ASSERT( nullptr != f);
if ( scheduler_ == f->scheduler_) {
// local scheduler
scheduler_->signal( f);
} else {
// scheduler in another thread
f->scheduler_->signal( f);
}
}
std::size_t