FM / detail

/usr/include/boost/fiber/detail

Name	Size	Mode	Actions
config.hpp	1828	0644	edit dl rm
context_spinlock_queue.hpp	2677	0644	edit dl rm
context_spmc_queue.hpp	6848	0644	edit dl rm
convert.hpp	1039	0644	edit dl rm
cpu_relax.hpp	2554	0644	edit dl rm
data.hpp	1132	0644	edit dl rm
decay_copy.hpp	733	0644	edit dl rm
disable_overload.hpp	802	0644	edit dl rm
exchange.hpp	734	0644	edit dl rm
fss.hpp	1393	0644	edit dl rm
futex.hpp	1556	0644	edit dl rm
is_all_same.hpp	1022	0644	edit dl rm
rtm.hpp	1791	0644	edit dl rm
spinlock.hpp	2168	0644	edit dl rm
spinlock_rtm.hpp	4845	0644	edit dl rm
spinlock_status.hpp	457	0644	edit dl rm
spinlock_ttas.hpp	5268	0644	edit dl rm
spinlock_ttas_adaptive.hpp	5944	0644	edit dl rm
spinlock_ttas_adaptive_futex.hpp	6622	0644	edit dl rm
spinlock_ttas_futex.hpp	5879	0644	edit dl rm
thread_barrier.hpp	1540	0644	edit dl rm

Edit: /usr/include/boost/fiber/detail/thread_barrier.hpp (1540B)

#ifndef BOOST_FIBER_DETAIL_THREAD_BARRIER_H
#define BOOST_FIBER_DETAIL_THREAD_BARRIER_H

#include <cstddef>
#include <condition_variable>
#include <mutex>

#include <boost/assert.hpp>
#include <boost/config.hpp>

#include <boost/fiber/detail/config.hpp>

#ifdef BOOST_HAS_ABI_HEADERS
# include BOOST_ABI_PREFIX
#endif

namespace boost {
namespace fibers {
namespace detail {

class thread_barrier {
private:
	std::size_t             initial_;
	std::size_t             current_;
	bool                    cycle_{ true };
    std::mutex              mtx_{};
    std::condition_variable cond_{};

public:
	explicit thread_barrier( std::size_t initial) :
        initial_{ initial },
        current_{ initial_ } {
        BOOST_ASSERT ( 0 != initial);
    }

thread_barrier( thread_barrier const&) = delete;
    thread_barrier & operator=( thread_barrier const&) = delete;

bool wait() {
        std::unique_lock< std::mutex > lk( mtx_);
        const bool cycle = cycle_;
        if ( 0 == --current_) {
            cycle_ = ! cycle_;
            current_ = initial_;
            lk.unlock(); // no pessimization
            cond_.notify_all();
            return true;
        }
        cond_.wait( lk, [&](){ return cycle != cycle_; });
        return false;
    }
};

}}}

#endif // BOOST_FIBER_DETAIL_THREAD_BARRIER_H

// 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_FIBER_DETAIL_THREAD_BARRIER_H #define BOOST_FIBER_DETAIL_THREAD_BARRIER_H #include #include #include #include #include #include #ifdef BOOST_HAS_ABI_HEADERS # include BOOST_ABI_PREFIX #endif namespace boost { namespace fibers { namespace detail { class thread_barrier { private: std::size_t initial_; std::size_t current_; bool cycle_{ true }; std::mutex mtx_{}; std::condition_variable cond_{}; public: explicit thread_barrier( std::size_t initial) : initial_{ initial }, current_{ initial_ } { BOOST_ASSERT ( 0 != initial); } thread_barrier( thread_barrier const&) = delete; thread_barrier & operator=( thread_barrier const&) = delete; bool wait() { std::unique_lock< std::mutex > lk( mtx_); const bool cycle = cycle_; if ( 0 == --current_) { cycle_ = ! cycle_; current_ = initial_; lk.unlock(); // no pessimization cond_.notify_all(); return true; } cond_.wait( lk, [&](){ return cycle != cycle_; }); return false; } }; }}} #endif // BOOST_FIBER_DETAIL_THREAD_BARRIER_H