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

refactor scheduler::dispatch()

Browse Source
This commit is contained in:
Oliver Kowalke
2015-11-25 19:24:11 +01:00
parent 6112d85a1a
commit 26227e31b2
1 changed files with 11 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/scheduler.cpp
View File

@@ -156,15 +156,19 @@ scheduler::dispatch() {
while ( ! shutdown_) {
// release termianted context'
release_terminated_();
// get sleeping context'
sleep2ready_();
// get context' from remote ready-queue
remote_ready2ready_();
context * ctx = nullptr;
// loop till we get next ready context
while ( nullptr == ( ctx = get_next_() ) ) {
// get context' from remote ready-queue
remote_ready2ready_();
// get sleeping context'
sleep2ready_();
// get next ready context
context * ctx = get_next_();
if ( nullptr != ctx) {
// push dispatcher-context to ready-queue
// so that ready-queue never becomes empty
sched_algo_->awakened( dispatcher_ctx_.get() );
resume_( dispatcher_ctx_.get(), ctx, nullptr);
BOOST_ASSERT( context::active() == dispatcher_ctx_.get() );
} else {
// no ready context, wait till signaled
// set deadline to highest value
std::chrono::steady_clock::time_point suspend_time =
@@ -176,18 +180,7 @@ scheduler::dispatch() {
}
// no ready context, wait till signaled
sched_algo_->suspend_until( suspend_time);
// get sleeping context'
sleep2ready_();
// TODO: pump external event-loop like boost::asio::io_service
// react on external interrupt signals
// react on requesting work sharing scenario
// no ready context, wait till signaled
}
// push dispatcher-context to ready-queue
// so that ready-queue never becomes empty
sched_algo_->awakened( dispatcher_ctx_.get() );
resume_( dispatcher_ctx_.get(), ctx, nullptr);
BOOST_ASSERT( context::active() == dispatcher_ctx_.get() );
}
// loop till all context' have been terminated
std::unique_lock< detail::spinlock > lk( worker_splk_);