Merge pull request #5 from KjellKod/COPY

Copy

Author: Kjell Hedström

src/q/mpmc_flexible_lock_queue.hpp

@@ -54,7 +54,7 @@ namespace mpmc {
 
       // -1 : unbounded
       // 0 ... N : bounded (0 is silly)
-      flexible_lock_queue(int maxSize = kSmallDefault);
+      flexible_lock_queue(const int maxSize = kSmallDefault);
 
       bool lock_free() const;
       bool push(T& item);

test/test_queue.cpp

@@ -47,13 +47,28 @@ void ProdConsInitialization(Prod& prod, Cons& cons ) {
 }
 
 
+
+
 TEST(Queue, ProdConsInitialization) {
    auto queue = queue_api::CreateQueue<FlexibleQ>(10);
    auto producer = std::get<queue_api::index::sender>(queue);
    auto consumer = std::get<queue_api::index::receiver>(queue);
 }
 
 
+
+TEST(Queue, ProdConsInitializationCopy) {
+   using namespace queue_api;
+   using QueuePair = std::pair<Sender<FlexibleQ>, Receiver<FlexibleQ>>;
+   QueuePair queue  = CreateQueue<FlexibleQ>(10);
+   Sender<FlexibleQ> sender1 = std::get<index::sender>(queue);
+   Sender<FlexibleQ> sender2(std::get<index::sender>(queue));
+   Receiver<FlexibleQ> receiver1 = std::get<index::receiver>(queue);
+   Receiver<FlexibleQ> receiver2(std::get<index::receiver>(queue));
+}
+
+
+
 struct HasWaitAndPop{
    std::chrono::milliseconds value;
    std::string element;