|
| 1 | +#pragma once |
| 2 | + |
| 3 | +#include <stdx/bit.hpp> |
| 4 | +#include <stdx/bitset.hpp> |
| 5 | +#include <stdx/compiler.hpp> |
| 6 | +#include <stdx/concepts.hpp> |
| 7 | +#include <stdx/detail/bitset_common.hpp> |
| 8 | +#include <stdx/type_traits.hpp> |
| 9 | +#include <stdx/udls.hpp> |
| 10 | + |
| 11 | +#include <algorithm> |
| 12 | +#include <atomic> |
| 13 | +#include <cstddef> |
| 14 | +#include <iterator> |
| 15 | +#include <limits> |
| 16 | +#include <string_view> |
| 17 | + |
| 18 | +namespace stdx { |
| 19 | +inline namespace v1 { |
| 20 | +namespace detail { |
| 21 | +template <std::size_t N, typename StorageElem> class atomic_bitset { |
| 22 | + constexpr static auto bit = StorageElem{1U}; |
| 23 | + |
| 24 | + static_assert(N <= std::numeric_limits<StorageElem>::digits, |
| 25 | + "atomic_bitset is limited to a single storage element"); |
| 26 | + static_assert(std::atomic<StorageElem>::is_always_lock_free, |
| 27 | + "atomic_bitset is not lock free"); |
| 28 | + std::atomic<StorageElem> storage{}; |
| 29 | + |
| 30 | + constexpr static auto mask = bit_mask<StorageElem, N - 1>(); |
| 31 | + StorageElem salient_value(std::memory_order order) const { |
| 32 | + return storage.load(order) & mask; |
| 33 | + } |
| 34 | + |
| 35 | + [[nodiscard]] static constexpr auto |
| 36 | + value_from_string(std::string_view str, std::size_t pos, std::size_t n, |
| 37 | + char one) -> StorageElem { |
| 38 | + StorageElem ret{}; |
| 39 | + auto const len = std::min(n, str.size() - pos); |
| 40 | + auto const s = str.substr(pos, std::min(len, N)); |
| 41 | + auto i = bit; |
| 42 | + for (auto it = std::rbegin(s); it != std::rend(s); ++it) { |
| 43 | + if (*it == one) { |
| 44 | + ret |= i; |
| 45 | + } |
| 46 | + i <<= 1u; |
| 47 | + } |
| 48 | + return ret; |
| 49 | + } |
| 50 | + |
| 51 | + using bitset_t = bitset<N, StorageElem>; |
| 52 | + |
| 53 | + public: |
| 54 | + constexpr atomic_bitset() = default; |
| 55 | + constexpr explicit atomic_bitset(std::uint64_t value) |
| 56 | + : storage{static_cast<StorageElem>(value & mask)} {} |
| 57 | + |
| 58 | + template <typename... Bs> |
| 59 | + constexpr explicit atomic_bitset(place_bits_t, Bs... bs) |
| 60 | + : storage{static_cast<StorageElem>( |
| 61 | + (StorageElem{} | ... | |
| 62 | + static_cast<StorageElem>(bit << to_underlying(bs))))} {} |
| 63 | + |
| 64 | + constexpr explicit atomic_bitset(all_bits_t) : storage{mask} {} |
| 65 | + |
| 66 | + constexpr explicit atomic_bitset(std::string_view str, std::size_t pos = 0, |
| 67 | + std::size_t n = std::string_view::npos, |
| 68 | + char one = '1') |
| 69 | + : storage{value_from_string(str, pos, n, one)} {} |
| 70 | + |
| 71 | + template <typename T> |
| 72 | + [[nodiscard]] auto |
| 73 | + to(std::memory_order order = std::memory_order_seq_cst) const -> T { |
| 74 | + using U = underlying_type_t<T>; |
| 75 | + static_assert( |
| 76 | + unsigned_integral<U>, |
| 77 | + "Conversion must be to an unsigned integral type or enum!"); |
| 78 | + static_assert(N <= std::numeric_limits<U>::digits, |
| 79 | + "atomic_bitset too big for conversion to T"); |
| 80 | + return static_cast<T>(storage.load(order)); |
| 81 | + } |
| 82 | + |
| 83 | + [[nodiscard]] auto |
| 84 | + to_natural(std::memory_order order = std::memory_order_seq_cst) const { |
| 85 | + return storage.load(order); |
| 86 | + } |
| 87 | + |
| 88 | + operator bitset_t() const { return bitset_t{storage.load()}; } |
| 89 | + |
| 90 | + auto load(std::memory_order order = std::memory_order_seq_cst) const |
| 91 | + -> bitset_t { |
| 92 | + return bitset_t{storage.load(order)}; |
| 93 | + } |
| 94 | + auto store(bitset_t b, |
| 95 | + std::memory_order order = std::memory_order_seq_cst) { |
| 96 | + storage.store(b.template to<StorageElem>(), order); |
| 97 | + } |
| 98 | + |
| 99 | + constexpr static std::integral_constant<std::size_t, N> size{}; |
| 100 | + |
| 101 | + bool is_lock_free() const noexcept { return storage.is_lock_free(); } |
| 102 | + constexpr static std::bool_constant< |
| 103 | + std::atomic<StorageElem>::is_always_lock_free> |
| 104 | + is_always_lock_free{}; |
| 105 | + |
| 106 | + template <typename T> [[nodiscard]] auto operator[](T idx) const -> bool { |
| 107 | + auto const pos = static_cast<std::size_t>(to_underlying(idx)); |
| 108 | + return (salient_value(std::memory_order_seq_cst) & (bit << pos)) != 0; |
| 109 | + } |
| 110 | + |
| 111 | + template <typename T> |
| 112 | + auto set(T idx, bool value = true, |
| 113 | + std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 114 | + auto const pos = static_cast<std::size_t>(to_underlying(idx)); |
| 115 | + if (value) { |
| 116 | + return bitset_t{ |
| 117 | + storage.fetch_or(static_cast<StorageElem>(bit << pos), order)}; |
| 118 | + } |
| 119 | + return bitset_t{ |
| 120 | + storage.fetch_and(static_cast<StorageElem>(~(bit << pos)), order)}; |
| 121 | + } |
| 122 | + |
| 123 | + auto set(lsb_t lsb, msb_t msb, bool value = true, |
| 124 | + std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 125 | + auto const l = to_underlying(lsb); |
| 126 | + auto const m = to_underlying(msb); |
| 127 | + auto const shifted_value = bit_mask<StorageElem>(m, l); |
| 128 | + if (value) { |
| 129 | + return bitset_t{storage.fetch_or(shifted_value, order)}; |
| 130 | + } |
| 131 | + return bitset_t{storage.fetch_and(~shifted_value, order)}; |
| 132 | + } |
| 133 | + |
| 134 | + auto set(lsb_t lsb, length_t len, bool value = true, |
| 135 | + std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 136 | + auto const l = to_underlying(lsb); |
| 137 | + auto const length = to_underlying(len); |
| 138 | + return set(lsb, static_cast<msb_t>(l + length - 1), value, order); |
| 139 | + } |
| 140 | + |
| 141 | + auto set(std::memory_order order = std::memory_order_seq_cst) |
| 142 | + LIFETIMEBOUND -> atomic_bitset & { |
| 143 | + storage.store(mask, order); |
| 144 | + return *this; |
| 145 | + } |
| 146 | + |
| 147 | + template <typename T> auto reset(T idx) -> bitset_t { |
| 148 | + auto const pos = static_cast<std::size_t>(to_underlying(idx)); |
| 149 | + return bitset_t{ |
| 150 | + storage.fetch_and(static_cast<StorageElem>(~(bit << pos)))}; |
| 151 | + } |
| 152 | + |
| 153 | + auto reset(std::memory_order order = std::memory_order_seq_cst) |
| 154 | + LIFETIMEBOUND -> atomic_bitset & { |
| 155 | + storage.store(StorageElem{}, order); |
| 156 | + return *this; |
| 157 | + } |
| 158 | + |
| 159 | + auto |
| 160 | + reset(lsb_t lsb, msb_t msb, |
| 161 | + std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 162 | + return set(lsb, msb, false, order); |
| 163 | + } |
| 164 | + |
| 165 | + auto |
| 166 | + reset(lsb_t lsb, length_t len, |
| 167 | + std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 168 | + return set(lsb, len, false, order); |
| 169 | + } |
| 170 | + |
| 171 | + template <typename T> |
| 172 | + auto flip(T idx, |
| 173 | + std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 174 | + auto const pos = static_cast<std::size_t>(to_underlying(idx)); |
| 175 | + return bitset_t{ |
| 176 | + storage.fetch_xor(static_cast<StorageElem>(bit << pos), order)}; |
| 177 | + } |
| 178 | + |
| 179 | + auto flip(std::memory_order order = std::memory_order_seq_cst) -> bitset_t { |
| 180 | + return bitset_t{storage.fetch_xor(mask, order)}; |
| 181 | + } |
| 182 | + |
| 183 | + [[nodiscard]] auto |
| 184 | + all(std::memory_order order = std::memory_order_seq_cst) const -> bool { |
| 185 | + return salient_value(order) == mask; |
| 186 | + } |
| 187 | + [[nodiscard]] auto |
| 188 | + any(std::memory_order order = std::memory_order_seq_cst) const -> bool { |
| 189 | + return salient_value(order) != 0; |
| 190 | + } |
| 191 | + [[nodiscard]] auto |
| 192 | + none(std::memory_order order = std::memory_order_seq_cst) const -> bool { |
| 193 | + return salient_value(order) == 0; |
| 194 | + } |
| 195 | + |
| 196 | + [[nodiscard]] auto |
| 197 | + count(std::memory_order order = std::memory_order_seq_cst) const |
| 198 | + -> std::size_t { |
| 199 | + return static_cast<std::size_t>(popcount(salient_value(order))); |
| 200 | + } |
| 201 | +}; |
| 202 | +} // namespace detail |
| 203 | + |
| 204 | +template <auto N, typename StorageElem = void> |
| 205 | +using atomic_bitset = detail::atomic_bitset< |
| 206 | + to_underlying(N), decltype(smallest_uint<to_underlying(N), StorageElem>())>; |
| 207 | +} // namespace v1 |
| 208 | +} // namespace stdx |
0 commit comments