Adds queue test header file
authorPeizhao Ou <peizhaoo@uci.edu>
Tue, 13 Feb 2018 06:16:01 +0000 (22:16 -0800)
committerPeizhao Ou <peizhaoo@uci.edu>
Tue, 13 Feb 2018 06:16:01 +0000 (22:16 -0800)
folly/stress-test/queue_test.h [new file with mode: 0644]

diff --git a/folly/stress-test/queue_test.h b/folly/stress-test/queue_test.h
new file mode 100644 (file)
index 0000000..8a75ac9
--- /dev/null
@@ -0,0 +1,40 @@
+#ifndef _FOLLY_QUEUE_TEST_H
+#define _FOLLY_QUEUE_TEST_H
+
+#include <folly/concurrency/UnboundedQueue.h>
+#include <folly/concurrency/DynamicBoundedQueue.h>
+#include <folly/AtomicLinkedList.h>
+#include <folly/MPMCQueue.h>
+
+#include <cds_test/stress_test.h>
+#include <cds_test/stress_test_util.h>
+
+#include <algorithm>
+#include <iostream>
+#include <memory>
+#include <random>
+#include <thread>
+
+namespace folly_test {
+
+// Unbounded queue
+typedef folly::USPSCQueue<size_t, false> USPSCQueue;
+typedef folly::UMPSCQueue<size_t, false> UMPSCQueue;
+typedef folly::USPMCQueue<size_t, false> USPMCQueue;
+typedef folly::UMPMCQueue<size_t, false> UMPMCQueue;
+
+// Dynamic bounded queue
+typedef folly::DSPSCQueue<size_t, false> DSPSCQueue;
+typedef folly::DMPSCQueue<size_t, false> DMPSCQueue;
+typedef folly::DSPMCQueue<size_t, false> DSPMCQueue;
+typedef folly::DMPMCQueue<size_t, false> DMPMCQueue;
+
+// AtomicLinkedList
+typedef folly::AtomicLinkedList<size_t> AtomicLinkedList;
+
+// MPMC Queue (linearizable)
+typedef folly::MPMCQueue<size_t> MPMCQueue;
+
+} // namespace folly_test
+
+#endif