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

add joining a fiber

Browse Source
This commit is contained in:
Oliver Kowalke
2015-09-16 20:51:26 +02:00
parent ddc5af0a36
commit a8e90aedb8
8 changed files with 369 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/context.cpp
View File

@@ -20,12 +20,10 @@ static context * make_main_context() {
static thread_local context main_ctx( main_context);
// scheduler for this thread
static thread_local scheduler sched;
// attach scheduler to main fiber context
main_ctx.set_scheduler( & sched);
// attach main fiber context to scheduler
sched.set_main_context( & main_ctx);
// create and attach dispatching fiber context to scheduler
sched.set_dispatching_context(
// create and attach dispatcher fiber context to scheduler
sched.set_dispatcher_context(
make_dispatcher_context( & sched) );
return & main_ctx;
}
@@ -120,11 +118,25 @@ context::release() noexcept {
wait_queue_t::iterator e = wait_queue_.end();
for ( wait_queue_t::iterator i = wait_queue_.begin(); i != e;) {
context * f = & ( * i);
// remove fiber from wait-queue
i = wait_queue_.erase( i);
//FIXME: signal that f might resume
// notify scheduler
scheduler_->set_ready( f);
}
}
void
context::join() noexcept {
// get active context
context * active_ctx = context::active();
// push active context to wait-queue, member
// of the context which has to be joined by
// the active context
wait_queue_.push_back( * active_ctx);
// suspend active context
scheduler_->re_schedule( active_ctx);
}
bool
context::wait_is_linked() {
return wait_hook_.is_linked();