2 #include <cds/container/chase-lev-deque.h>
3 #include <cds_test/stress_test.h>
13 typedef cds_others::ChaseLevDeque Deque;
14 static size_t s_nDequeStealerThreadCount = 5;
15 static size_t s_nDequeMainPassCount = 100000000;
17 class ChaseLevDequeTest : public cds_test::stress_fixture {
20 static atomic_int terminate_stealer;
22 static ullong *succ_counts;
23 static ullong push_sum;
24 static ullong push_count;
26 static void SetUpTestCase() {
27 cds_test::config const &cfg = get_config("Misc");
28 GetConfig(DequeStealerThreadCount);
29 GetConfig(DequeMainPassCount);
32 static void StealerThread(int index) {
33 while (!terminate_stealer.load(memory_order_relaxed)) {
34 int res = deque->steal();
35 if (res != EMPTY && res != ABORT) {
42 static void MainThread(int index, int push_percentage) {
43 for (ullong i = 0; i < s_nDequeMainPassCount; i++) {
44 if ((::rand() % 100) < push_percentage) {
45 int item = ::rand() % 100;
50 int res = deque->take();
58 int res = deque->take();
69 atomic_int ChaseLevDequeTest::terminate_stealer;
70 ullong *ChaseLevDequeTest::sums;
71 ullong *ChaseLevDequeTest::succ_counts;
72 ullong ChaseLevDequeTest::push_count;
73 ullong ChaseLevDequeTest::push_sum;
74 Deque *ChaseLevDequeTest::deque;
76 TEST_F(ChaseLevDequeTest, DequePushPopTake) {
79 sums = (ullong *)calloc(1, sizeof(ullong) * (s_nDequeStealerThreadCount + 1));
81 (ullong *)calloc(1, sizeof(ullong) * (s_nDequeStealerThreadCount + 1));
85 std::thread *threads = new std::thread[s_nDequeStealerThreadCount];
86 for (ullong i = 0; i < s_nDequeStealerThreadCount; i++) {
87 threads[i] = std::thread(StealerThread, i);
90 for (int i = 90; i > 0; i -= 10) {
91 MainThread(s_nDequeStealerThreadCount, i);
94 terminate_stealer.store(1, memory_order_relaxed);
95 for (ullong i = 0; i < s_nDequeStealerThreadCount; i++) {
100 ullong received_sum = 0;
101 ullong overall_count = 0;
102 for (ullong i = 0; i <= s_nDequeStealerThreadCount; i++) {
103 received_sum += sums[i];
104 overall_count += succ_counts[i];
106 if (overall_count != push_count || received_sum != push_sum) {
107 cout << "Incorrect deque\n";
108 cout << "Push sum: " << push_sum << "\n";
109 cout << "Received sum:" << received_sum << "\n";
110 cout << "Push count=" << push_count << "\n";
111 cout << "Received count:" << overall_count << "\n";