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

use fibers::mutext instead std::mutex in workstealing example

Browse Source
This commit is contained in:
Oliver Kowalke
2015-01-05 19:58:07 +01:00
parent fbe98be71e
commit 37747ece0d
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
examples/migration/workstealing_round_robin.cpp
View File

@@ -13,18 +13,18 @@
#endif
void
workstealing_round_robin::awakened( boost::fibers::detail::fiber_handle & f)
workstealing_round_robin::awakened( boost::fibers::fiber_handle & f)
{
std::unique_lock< std::mutex > lk( mtx_);
std::unique_lock< boost::fibers::mutex > lk( mtx_);
BOOST_ASSERT( f->is_ready() );
rqueue_.push_back( f);
}
boost::fibers::detail::fiber_handle
boost::fibers::fiber_handle
workstealing_round_robin::pick_next()
{
std::unique_lock< std::mutex > lk( mtx_);
boost::fibers::detail::fiber_handle f;
std::unique_lock< boost::fibers::mutex > lk( mtx_);
boost::fibers::fiber_handle f;
if ( ! rqueue_.empty() )
{
f = rqueue_.front();
@@ -37,8 +37,8 @@ workstealing_round_robin::pick_next()
boost::fibers::fiber
workstealing_round_robin::steal()
{
std::unique_lock< std::mutex > lk( mtx_);
for ( boost::fibers::detail::fiber_handle f : rqueue_)
std::unique_lock< boost::fibers::mutex > lk( mtx_);
for ( boost::fibers::fiber_handle f : rqueue_)
{
if ( ! f->thread_affinity() )
{

8
examples/migration/workstealing_round_robin.hpp
View File

@@ -20,15 +20,15 @@
class workstealing_round_robin : public boost::fibers::sched_algorithm
{
private:
typedef std::list< boost::fibers::detail::fiber_handle > rqueue_t;
typedef std::list< boost::fibers::fiber_handle > rqueue_t;
std::mutex mtx_;
boost::fibers::mutex mtx_;
rqueue_t rqueue_;
public:
virtual void awakened( boost::fibers::detail::fiber_handle &);
virtual void awakened( boost::fibers::fiber_handle &);
virtual boost::fibers::detail::fiber_handle pick_next();
virtual boost::fibers::fiber_handle pick_next();
boost::fibers::fiber steal();
};