123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110 |
- // Copyright (C) 2011 Tim Blechmann
- //
- // 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_LOCKFREE_TEST_HELPERS
- #define BOOST_LOCKFREE_TEST_HELPERS
- #include <set>
- #include <boost/array.hpp>
- #include <boost/lockfree/detail/atomic.hpp>
- #include <boost/thread.hpp>
- #include <boost/cstdint.hpp>
- template <typename int_type>
- int_type generate_id(void)
- {
- static boost::lockfree::detail::atomic<int_type> generator(0);
- return ++generator;
- }
- template <typename int_type, size_t buckets>
- class static_hashed_set
- {
- public:
- int calc_index(int_type id)
- {
- // knuth hash ... does not need to be good, but has to be portable
- size_t factor = size_t((float)buckets * 1.616f);
- return ((size_t)id * factor) % buckets;
- }
- bool insert(int_type const & id)
- {
- std::size_t index = calc_index(id);
- boost::lock_guard<boost::mutex> lock (ref_mutex[index]);
- std::pair<typename std::set<int_type>::iterator, bool> p;
- p = data[index].insert(id);
- return p.second;
- }
- bool find (int_type const & id)
- {
- std::size_t index = calc_index(id);
- boost::lock_guard<boost::mutex> lock (ref_mutex[index]);
- return data[index].find(id) != data[index].end();
- }
- bool erase(int_type const & id)
- {
- std::size_t index = calc_index(id);
- boost::lock_guard<boost::mutex> lock (ref_mutex[index]);
- if (data[index].find(id) != data[index].end()) {
- data[index].erase(id);
- assert(data[index].find(id) == data[index].end());
- return true;
- }
- else
- return false;
- }
- std::size_t count_nodes(void) const
- {
- std::size_t ret = 0;
- for (int i = 0; i != buckets; ++i) {
- boost::lock_guard<boost::mutex> lock (ref_mutex[i]);
- ret += data[i].size();
- }
- return ret;
- }
- private:
- boost::array<std::set<int_type>, buckets> data;
- mutable boost::array<boost::mutex, buckets> ref_mutex;
- };
- struct test_equal
- {
- test_equal(int i):
- i(i)
- {}
- void operator()(int arg) const
- {
- BOOST_REQUIRE_EQUAL(arg, i);
- }
- int i;
- };
- struct dummy_functor
- {
- void operator()(int /* arg */) const
- {
- }
- };
- #endif
|