1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
// Copyright 2019 Hans Dembinski
//
// 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/core/lightweight_test.hpp>
#include <boost/histogram/accumulators/ostream.hpp>
#include <boost/histogram/accumulators/thread_safe.hpp>
#include "throw_exception.hpp"
#include <boost/histogram/storage_adaptor.hpp>
#include <array>
#include <deque>
#include <map>
#include <thread>
#include <unordered_map>
#include <vector>
using namespace boost::histogram;
constexpr auto n_fill = 1000000;
template <class T>
void tests() {
{
storage_adaptor<T> s;
s.reset(1);
auto fill = [&s]() {
for (unsigned i = 0; i < n_fill; ++i) {
++s[0];
s[0] += 1;
}
};
std::thread t1(fill);
std::thread t2(fill);
std::thread t3(fill);
std::thread t4(fill);
t1.join();
t2.join();
t3.join();
t4.join();
BOOST_TEST_EQ(s[0], 4 * 2 * n_fill);
}
}
int main() {
using ts_int = accumulators::thread_safe<int>;
tests<std::vector<ts_int>>();
tests<std::array<ts_int, 100>>();
tests<std::deque<ts_int>>();
// stdlib maps are not thread-safe and not supported
return boost::report_errors();
}
|
