2 #include <cds/container/chase-lev-deque.h>
3 #include <cds_test/stress_test.h>
14 typedef cds_others::ChaseLevDeque Deque;
15 static size_t s_nDequeStealerThreadCount = 5;
16 static size_t s_nDequeMainPassCount = 100000000;
18 class ChaseLevDequeTest : public cds_test::stress_fixture {
21 static atomic_int terminate_stealer;
23 static ullong *succ_counts;
24 static ullong push_sum;
25 static ullong push_count;
27 static void SetUpTestCase() {
28 cds_test::config const &cfg = get_config("Misc");
29 GetConfig(DequeStealerThreadCount);
30 GetConfig(DequeMainPassCount);
33 static void StealerThread(int index) {
34 while (!terminate_stealer.load(memory_order_relaxed)) {
35 int res = deque->steal();
36 if (res != EMPTY && res != ABORT) {
43 static void MainThread(int index, int push_percentage) {
44 for (ullong i = 0; i < s_nDequeMainPassCount; i++) {
45 if ((::rand() % 100) < push_percentage) {
46 int item = ::rand() % 100;
51 int res = deque->take();
59 int res = deque->take();
70 atomic_int ChaseLevDequeTest::terminate_stealer;
71 ullong *ChaseLevDequeTest::sums;
72 ullong *ChaseLevDequeTest::succ_counts;
73 ullong ChaseLevDequeTest::push_count;
74 ullong ChaseLevDequeTest::push_sum;
75 Deque *ChaseLevDequeTest::deque;
77 TEST_F(ChaseLevDequeTest, DequePushPopTake) {
80 sums = (ullong *)calloc(1, sizeof(ullong) * (s_nDequeStealerThreadCount + 1));
82 (ullong *)calloc(1, sizeof(ullong) * (s_nDequeStealerThreadCount + 1));
86 std::unique_ptr<std::thread[]> threads(
87 new std::thread[s_nDequeStealerThreadCount]);
88 for (ullong i = 0; i < s_nDequeStealerThreadCount; i++) {
89 threads[i] = std::thread(StealerThread, i);
92 for (int i = 90; i > 0; i -= 10) {
93 MainThread(s_nDequeStealerThreadCount, i);
96 terminate_stealer.store(1, memory_order_relaxed);
97 for (ullong i = 0; i < s_nDequeStealerThreadCount; i++) {
102 ullong received_sum = 0;
103 ullong overall_count = 0;
104 for (ullong i = 0; i <= s_nDequeStealerThreadCount; i++) {
105 received_sum += sums[i];
106 overall_count += succ_counts[i];
108 if (overall_count != push_count || received_sum != push_sum) {
109 cout << "Incorrect deque\n";
110 cout << "Push sum: " << push_sum << "\n";
111 cout << "Received sum:" << received_sum << "\n";
112 cout << "Push count=" << push_count << "\n";
113 cout << "Received count:" << overall_count << "\n";