folly/stress-test/queue_test.h

   1 #ifndef _FOLLY_QUEUE_TEST_H
   2 #define _FOLLY_QUEUE_TEST_H
   3
   4 #include <folly/concurrency/UnboundedQueue.h>
   5 #include <folly/concurrency/DynamicBoundedQueue.h>
   6 #include <folly/AtomicLinkedList.h>
   7 #include <folly/MPMCQueue.h>
   8
   9 #include <cds_test/stress_test.h>
  10 #include <cds_test/stress_test_util.h>
  11
  12 #include <algorithm>
  13 #include <iostream>
  14 #include <memory>
  15 #include <random>
  16 #include <thread>
  17
  18 namespace folly_test {
  19
  20 // Unbounded queue
  21 typedef folly::USPSCQueue<size_t, false> USPSCQueue;
  22 typedef folly::UMPSCQueue<size_t, false> UMPSCQueue;
  23 typedef folly::USPMCQueue<size_t, false> USPMCQueue;
  24 typedef folly::UMPMCQueue<size_t, false> UMPMCQueue;
  25
  26 // Dynamic bounded queue
  27 typedef folly::DSPSCQueue<size_t, false> DSPSCQueue;
  28 typedef folly::DMPSCQueue<size_t, false> DMPSCQueue;
  29 typedef folly::DSPMCQueue<size_t, false> DSPMCQueue;
  30 typedef folly::DMPMCQueue<size_t, false> DMPMCQueue;
  31
  32 // AtomicLinkedList
  33 typedef folly::AtomicLinkedList<size_t> AtomicLinkedList;
  34
  35 // MPMC Queue (linearizable)
  36 typedef folly::MPMCQueue<size_t> MPMCQueue;
  37
  38 } // namespace folly_test
  39
  40 #endif