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

equeue fiber first

Browse Source
This commit is contained in:
Oliver Kowalke
2014-03-16 13:44:36 +01:00
parent 8884e791b1
commit a3e8944fd0
3 changed files with 29 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/round_robin.cpp
View File

@@ -28,26 +28,8 @@
namespace boost {
namespace fibers {
round_robin::round_robin() BOOST_NOEXCEPT :
active_fiber_(),
wqueue_(),
rqueue_(),
mn_()
{}
round_robin::~round_robin() BOOST_NOEXCEPT
{
// fibers will be destroyed (stack-unwinding)
// if last reference goes out-of-scope
// therefore destructing wqueue_ && rqueue_
// will destroy the fibers in this scheduler
// if not referenced on other places
while ( ! wqueue_.empty() && ! rqueue_.empty() )
run();
}
void
round_robin::spawn( detail::worker_fiber::ptr_t const& f)
round_robin::resume_( detail::worker_fiber::ptr_t const& f)
{
BOOST_ASSERT( f);
BOOST_ASSERT( f->is_ready() );
@@ -67,6 +49,27 @@ round_robin::spawn( detail::worker_fiber::ptr_t const& f)
active_fiber_ = tmp;
}
round_robin::round_robin() BOOST_NOEXCEPT :
active_fiber_(),
wqueue_(),
rqueue_(),
mn_()
{}
round_robin::~round_robin() BOOST_NOEXCEPT
{
// fibers will be destroyed (stack-unwinding)
// if last reference goes out-of-scope
// therefore destructing wqueue_ && rqueue_
// will destroy the fibers in this scheduler
// if not referenced on other places
while ( ! wqueue_.empty() && ! rqueue_.empty() )
run();
}
void
round_robin::spawn( detail::worker_fiber::ptr_t const& f)
{ rqueue_.push_back( f); }
bool
round_robin::run()
{
@@ -109,7 +112,7 @@ round_robin::run()
while ( true);
// resume fiber
spawn( f);
resume_( f);
return true;
}