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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
// Copyright (C) 2011-2013 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)
#include <boost/lockfree/spsc_value.hpp>
#define BOOST_TEST_MAIN
#ifdef BOOST_LOCKFREE_INCLUDE_TESTS
# include <boost/test/included/unit_test.hpp>
#else
# include <boost/test/unit_test.hpp>
#endif
#include <cstdint>
BOOST_AUTO_TEST_CASE( spsc_value_test )
{
boost::lockfree::spsc_value< uint64_t > v;
auto validate_value = [ & ]( uint64_t expected ) {
uint64_t out {};
BOOST_TEST_REQUIRE( v.read( out ) == true );
BOOST_TEST_REQUIRE( out == expected );
};
auto validate_no_pending_update = [ & ] {
uint64_t out {};
BOOST_TEST_REQUIRE( v.read( out ) == false );
};
validate_no_pending_update();
v.write( 1 );
validate_value( 1 );
v.write( 2 );
validate_value( 2 );
v.write( 3 );
validate_value( 3 );
v.write( 4 );
validate_value( 4 );
validate_no_pending_update();
validate_no_pending_update();
validate_no_pending_update();
v.write( 5 );
v.write( 6 );
v.write( 7 );
validate_value( 7 );
}
BOOST_AUTO_TEST_CASE( spsc_value_test_allow_duplicate_reads )
{
boost::lockfree::spsc_value< uint64_t, boost::lockfree::allow_multiple_reads< true > > v { 0xff };
auto validate_value = [ & ]( uint64_t expected ) {
uint64_t out {};
BOOST_TEST_REQUIRE( v.read( out ) == true );
BOOST_TEST_REQUIRE( out == expected );
};
validate_value( 0xff );
v.write( 1 );
validate_value( 1 );
v.write( 2 );
validate_value( 2 );
v.write( 3 );
validate_value( 3 );
v.write( 4 );
validate_value( 4 );
validate_value( 4 );
validate_value( 4 );
validate_value( 4 );
v.write( 5 );
v.write( 6 );
v.write( 7 );
validate_value( 7 );
}
BOOST_AUTO_TEST_CASE( spsc_value_test_move_only_type )
{
auto make_t = [ & ]( uint64_t val ) {
return std::make_unique< uint64_t >( val );
};
boost::lockfree::spsc_value< std::unique_ptr< uint64_t > > v;
auto validate_value = [ & ]( uint64_t expected ) {
std::unique_ptr< uint64_t > out;
BOOST_TEST_REQUIRE( v.read( out ) == true );
BOOST_TEST_REQUIRE( *out == expected );
};
auto t1 = make_t( 1 );
auto t2 = make_t( 2 );
auto t3 = make_t( 3 );
v.write( std::move( t1 ) );
validate_value( 1 );
v.write( std::move( t2 ) );
BOOST_TEST_REQUIRE( v.consume( []( const std::unique_ptr< uint64_t >& out ) {
BOOST_TEST_REQUIRE( *out == uint64_t( 2 ) );
} ) );
v.write( std::move( t3 ) );
BOOST_TEST_REQUIRE( v.consume( []( std::unique_ptr< uint64_t > out ) {
BOOST_TEST_REQUIRE( *out == uint64_t( 3 ) );
} ) );
BOOST_TEST_REQUIRE( v.consume( []( std::unique_ptr< uint64_t > out ) {} ) == false );
std::unique_ptr< uint64_t > out;
BOOST_TEST_REQUIRE( v.read( out ) == false );
}
|
