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

remove class scheduler - fiber_context has static TLS

Browse Source 
- detail:.scheduler was removed
- fiber_context has a static thread-local pointer to the active
  fiber_context
- fiber_context has member to pointer of fiber_manager
- functions of fiber_manager are accessed only via fiber_context
- if fiber f is resumed, the fiber_manager of the current active fiber
  f' is assigned to f
  -> that is necessary if f was stolen form another thread
This commit is contained in:
Oliver Kowalke
2015-09-07 11:50:01 +02:00
parent 26ea3aa41c
commit 7233f617d7
18 changed files with 250 additions and 185 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/interruption.cpp
View File

@@ -20,45 +20,45 @@ namespace boost {
namespace this_fiber {
disable_interruption::disable_interruption() noexcept :
set_( ( fibers::detail::scheduler::instance()->active()->interruption_blocked() ) ) {
set_( ( fibers::fiber_context::active()->interruption_blocked() ) ) {
if ( ! set_) {
fibers::detail::scheduler::instance()->active()->interruption_blocked( true);
fibers::fiber_context::active()->interruption_blocked( true);
}
}
disable_interruption::~disable_interruption() noexcept {
if ( ! set_) {
fibers::detail::scheduler::instance()->active()->interruption_blocked( false);
fibers::fiber_context::active()->interruption_blocked( false);
}
}
restore_interruption::restore_interruption( disable_interruption & disabler) noexcept :
disabler_( disabler) {
if ( ! disabler_.set_) {
fibers::detail::scheduler::instance()->active()->interruption_blocked( false);
fibers::fiber_context::active()->interruption_blocked( false);
}
}
restore_interruption::~restore_interruption() noexcept {
if ( ! disabler_.set_) {
fibers::detail::scheduler::instance()->active()->interruption_blocked( true);
fibers::fiber_context::active()->interruption_blocked( true);
}
}
BOOST_FIBERS_DECL
bool interruption_enabled() noexcept {
return ! fibers::detail::scheduler::instance()->active()->interruption_blocked();
return ! fibers::fiber_context::active()->interruption_blocked();
}
BOOST_FIBERS_DECL
bool interruption_requested() noexcept {
return fibers::detail::scheduler::instance()->active()->interruption_requested();
return fibers::fiber_context::active()->interruption_requested();
}
BOOST_FIBERS_DECL
void interruption_point() {
if ( interruption_requested() && interruption_enabled() ) {
fibers::detail::scheduler::instance()->active()->request_interruption( false);
fibers::fiber_context::active()->request_interruption( false);
throw fibers::fiber_interrupted();
}
}