92 lines
1.9 KiB
C++
Raw Normal View History

#ifndef BOOST_ATOMIC_DETAIL_LOCKPOOL_HPP
#define BOOST_ATOMIC_DETAIL_LOCKPOOL_HPP
// Copyright (c) 2011 Helge Bahmann
//
// 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)
#include <boost/atomic/detail/config.hpp>
2014-03-01 11:00:20 -08:00
#include <boost/atomic/detail/link.hpp>
#ifndef BOOST_ATOMIC_FLAG_LOCK_FREE
2014-03-01 11:00:20 -08:00
#include <boost/smart_ptr/detail/lightweight_mutex.hpp>
#endif
2014-03-01 11:00:20 -08:00
#ifdef BOOST_HAS_PRAGMA_ONCE
#pragma once
#endif
namespace boost {
namespace atomics {
namespace detail {
#ifndef BOOST_ATOMIC_FLAG_LOCK_FREE
class lockpool
{
public:
2014-03-01 11:00:20 -08:00
typedef boost::detail::lightweight_mutex lock_type;
class scoped_lock :
public lock_type::scoped_lock
{
2014-03-01 11:00:20 -08:00
typedef lock_type::scoped_lock base_type;
public:
2014-03-01 11:00:20 -08:00
explicit scoped_lock(const volatile void * addr) : base_type(get_lock_for(addr))
{
}
2014-03-01 11:00:20 -08:00
BOOST_DELETED_FUNCTION(scoped_lock(scoped_lock const&))
BOOST_DELETED_FUNCTION(scoped_lock& operator=(scoped_lock const&))
};
private:
static BOOST_ATOMIC_DECL lock_type& get_lock_for(const volatile void * addr);
};
#else
class lockpool
{
public:
typedef atomic_flag lock_type;
class scoped_lock
{
private:
atomic_flag& flag_;
public:
explicit
scoped_lock(const volatile void * addr) : flag_(get_lock_for(addr))
{
for (; flag_.test_and_set(memory_order_acquire);)
{
#if defined(BOOST_ATOMIC_X86_PAUSE)
BOOST_ATOMIC_X86_PAUSE();
#endif
}
}
~scoped_lock(void)
{
flag_.clear(memory_order_release);
}
2014-03-01 11:00:20 -08:00
BOOST_DELETED_FUNCTION(scoped_lock(const scoped_lock &))
BOOST_DELETED_FUNCTION(scoped_lock& operator=(const scoped_lock &))
};
private:
static BOOST_ATOMIC_DECL lock_type& get_lock_for(const volatile void * addr);
};
#endif
}
}
}
#endif