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

add workstealing round_robin

Browse Source
This commit is contained in:
Oliver Kowalke
2013-10-25 18:01:56 +02:00
parent c19364b686
commit 436883ca33
10 changed files with 390 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
include/boost/fiber/algorithm.hpp
View File

@@ -51,9 +51,6 @@ struct algorithm : private noncopyable
virtual void yield() = 0;
virtual ~algorithm() {}
virtual fiber steal_from() = 0;
virtual void migrate_to( fiber const&) = 0;
};
}}

1
include/boost/fiber/all.hpp
View File

@@ -27,6 +27,7 @@
#include <boost/fiber/recursive_mutex.hpp>
#include <boost/fiber/recursive_timed_mutex.hpp>
#include <boost/fiber/round_robin.hpp>
#include <boost/fiber/round_robin_ws.hpp>
#include <boost/fiber/timed_mutex.hpp>
#include <boost/fiber/unbounded_queue.hpp>

7
include/boost/fiber/asio/round_robin.hpp
View File

@@ -8,13 +8,11 @@
#define BOOST_FIBERS_ASIO_ROUND_ROBIN_HPP
#include <deque>
#include <stdexcept>
#include <utility>
#include <boost/asio/io_service.hpp>
#include <boost/config.hpp>
#include <boost/thread/lock_types.hpp>
#include <boost/throw_exception.hpp>
#include <boost/fiber/algorithm.hpp>
#include <boost/fiber/detail/config.hpp>
@@ -83,11 +81,6 @@ public:
unique_lock< detail::spinlock > &);
void yield();
fiber steal_from()
{ BOOST_THROW_EXCEPTION( std::domain_error("not implemented") ); }
void migrate_to( fiber const&)
{ BOOST_THROW_EXCEPTION( std::domain_error("not implemented") ); }
};
}}}

7
include/boost/fiber/round_robin.hpp
View File

@@ -20,7 +20,6 @@
#include <boost/fiber/detail/config.hpp>
#include <boost/fiber/detail/fiber_base.hpp>
#include <boost/fiber/detail/spinlock.hpp>
#include <boost/fiber/detail/ws_queue.hpp>
#include <boost/fiber/fiber.hpp>
#ifdef BOOST_HAS_ABI_HEADERS
@@ -51,10 +50,11 @@ private:
};
typedef std::deque< schedulable > wqueue_t;
typedef std::deque< detail::fiber_base::ptr_t > rqueue_t;
detail::fiber_base::ptr_t active_fiber_;
wqueue_t wqueue_;
detail::ws_queue rqueue_;
rqueue_t rqueue_;
public:
round_robin() BOOST_NOEXCEPT;
@@ -77,9 +77,6 @@ public:
unique_lock< detail::spinlock > &);
void yield();
fiber steal_from();
void migrate_to( fiber const&);
};
}}

95
include/boost/fiber/round_robin_ws.hpp Normal file
View File

@@ -0,0 +1,95 @@
// Copyright Oliver Kowalke 2013.
// Distributed under the Boost Software License, Version 1.0.
// (See accompanying file LICENSE_1_0.txt or copy at
// http://www.boost.org/LICENSE_1_0.txt)
#ifndef BOOST_FIBERS_DEFAULT_SCHEDULER_WS_H
#define BOOST_FIBERS_DEFAULT_SCHEDULER_WS_H
#include <deque>
#include <boost/assert.hpp>
#include <boost/config.hpp>
#include <boost/multi_index_container.hpp>
#include <boost/multi_index/member.hpp>
#include <boost/multi_index/mem_fun.hpp>
#include <boost/multi_index/ordered_index.hpp>
#include <boost/thread/lock_types.hpp>
#include <boost/fiber/algorithm.hpp>
#include <boost/fiber/detail/config.hpp>
#include <boost/fiber/detail/fiber_base.hpp>
#include <boost/fiber/detail/spinlock.hpp>
#include <boost/fiber/detail/ws_queue.hpp>
#include <boost/fiber/fiber.hpp>
#ifdef BOOST_HAS_ABI_HEADERS
# include BOOST_ABI_PREFIX
#endif
# if defined(BOOST_MSVC)
# pragma warning(push)
# pragma warning(disable:4251 4275)
# endif
namespace boost {
namespace fibers {
class BOOST_FIBERS_DECL round_robin_ws : public algorithm
{
private:
struct schedulable
{
detail::fiber_base::ptr_t f;
clock_type::time_point tp;
schedulable( detail::fiber_base::ptr_t const& f_,
clock_type::time_point const& tp_ =
(clock_type::time_point::max)() ) :
f( f_), tp( tp_)
{ BOOST_ASSERT( f); }
};
typedef std::deque< schedulable > wqueue_t;
detail::fiber_base::ptr_t active_fiber_;
wqueue_t wqueue_;
detail::ws_queue rqueue_;
public:
round_robin_ws() BOOST_NOEXCEPT;
~round_robin_ws() BOOST_NOEXCEPT;
void spawn( detail::fiber_base::ptr_t const&);
void priority( detail::fiber_base::ptr_t const&, int);
void join( detail::fiber_base::ptr_t const&);
detail::fiber_base::ptr_t active() BOOST_NOEXCEPT
{ return active_fiber_; }
bool run();
void wait( unique_lock< detail::spinlock > &);
bool wait_until( clock_type::time_point const&,
unique_lock< detail::spinlock > &);
void yield();
fiber steal_from();
void migrate_to( fiber const&);
};
}}
# if defined(BOOST_MSVC)
# pragma warning(pop)
# endif
#ifdef BOOST_HAS_ABI_HEADERS
# include BOOST_ABI_SUFFIX
#endif
#endif // BOOST_FIBERS_DEFAULT_SCHEDULER_WS_H