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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
// Copyright 2015-2018 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/count.hpp>
#include <boost/histogram/accumulators/ostream.hpp>
#include <sstream>
#include <thread>
#include "str.hpp"
#include "throw_exception.hpp"
using namespace boost::histogram;
using namespace std::literals;
constexpr int N = 10000;
template <class F>
void parallel(F f) {
auto g = [&]() {
for (int i = 0; i < N; ++i) f();
};
std::thread a(g), b(g), c(g), d(g);
a.join();
b.join();
c.join();
d.join();
}
template <class T>
void test_on() {
using ts_t = accumulators::count<T, true>;
// default ctor
{
ts_t i;
BOOST_TEST_EQ(i, static_cast<T>(0));
}
// ctor from value
{
ts_t i{1001};
BOOST_TEST_EQ(i, static_cast<T>(1001));
BOOST_TEST_EQ(str(i), "1001"s);
}
// add null
BOOST_TEST_EQ(ts_t{} += ts_t{}, ts_t{});
// add non-null
BOOST_TEST_EQ((ts_t{} += ts_t{2}), (ts_t{2}));
// operator++
{
ts_t t;
parallel([&]() { ++t; });
BOOST_TEST_EQ(t, static_cast<T>(4 * N));
}
// operator+= with value
{
ts_t t;
parallel([&]() { t += 2; });
BOOST_TEST_EQ(t, static_cast<T>(8 * N));
}
// operator+= with another thread-safe
{
ts_t t, u;
u = 2;
parallel([&]() { t += u; });
BOOST_TEST_EQ(t, static_cast<T>(8 * N));
}
}
int main() {
test_on<int>();
test_on<float>();
// copy and assignment from other thread-safe
{
accumulators::count<char, true> r{1};
accumulators::count<int, true> a{r}, b;
b = r;
BOOST_TEST_EQ(a, 1);
BOOST_TEST_EQ(b, 1);
}
return boost::report_errors();
}
|
