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

request unwinding and resume fibers at end of dispatch()

Browse Source
This commit is contained in:
Oliver Kowalke
2015-10-18 09:08:15 +02:00
parent e63186adfe
commit 5f5a607d87
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/scheduler.cpp
View File

@@ -209,17 +209,25 @@ scheduler::dispatch() {
release_terminated_();
// force unwinding of all context' in worker-queue
worker_queue_t::iterator e = worker_queue_.end();
for ( worker_queue_t::iterator i = worker_queue_.begin(); i != e; ++i) {
context * ctx = & ( * i);
for ( worker_queue_t::iterator i = worker_queue_.begin(); i != e;) {
context * ctx = & ( worker_queue_.front() );
BOOST_ASSERT( ! ctx->is_main_context() );
BOOST_ASSERT( ! ctx->is_dispatcher_context() );
if ( ctx->is_terminated() ) {
i = worker_queue_.erase( i);
} else {
ctx->request_unwinding();
set_ready( ctx);
set_ready( ctx);
++i;
}
}
context * ctx = nullptr;
if ( nullptr != ( ctx = get_next_() ) ) {
// resume ready context's
sched_algo_->awakened( dispatcher_ctx_.get() );
resume_( dispatcher_ctx_.get(), ctx, nullptr);
BOOST_ASSERT( context::active() == dispatcher_ctx_.get() );
}
}
// release termianted context'
release_terminated_();