fcpqueue_vector.cpp 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134
  1. // Copyright (c) 2006-2018 Maxim Khizhinsky
  2. //
  3. // Distributed under the Boost Software License, Version 1.0. (See accompanying
  4. // file LICENSE or copy at http://www.boost.org/LICENSE_1_0.txt)
  5. #include "test_fcpqueue.h"
  6. #include <cds/container/fcpriority_queue.h>
  7. namespace cds_test {
  8. TEST_F( FCPQueue, vector )
  9. {
  10. typedef cds::container::FCPriorityQueue< FCPQueue::value_type > pqueue_type;
  11. pqueue_type pq;
  12. test( pq );
  13. }
  14. TEST_F( FCPQueue, vector_empty_wait_strategy )
  15. {
  16. struct pqueue_traits : public cds::container::fcpqueue::traits
  17. {
  18. typedef cds::container::fcpqueue::stat<> stat;
  19. typedef cds::algo::flat_combining::wait_strategy::empty wait_strategy;
  20. };
  21. typedef cds::container::FCPriorityQueue<
  22. value_type
  23. , std::priority_queue<
  24. value_type
  25. , std::vector<value_type>
  26. , less
  27. >
  28. , pqueue_traits
  29. > pqueue_type;
  30. pqueue_type pq;
  31. test( pq );
  32. }
  33. TEST_F( FCPQueue, vector_multi_mutex_multi_condvar )
  34. {
  35. struct pqueue_traits : public cds::container::fcpqueue::traits
  36. {
  37. typedef cds::container::fcpqueue::stat<> stat;
  38. typedef cds::algo::flat_combining::wait_strategy::multi_mutex_multi_condvar<> wait_strategy;
  39. };
  40. typedef cds::container::FCPriorityQueue<
  41. value_type
  42. , std::priority_queue<
  43. value_type
  44. , std::vector<value_type>
  45. , less
  46. >
  47. , pqueue_traits
  48. > pqueue_type;
  49. pqueue_type pq;
  50. test( pq );
  51. }
  52. TEST_F( FCPQueue, vector_stat )
  53. {
  54. struct pqueue_traits : public cds::container::fcpqueue::traits
  55. {
  56. typedef cds::container::fcpqueue::stat<> stat;
  57. };
  58. typedef cds::container::FCPriorityQueue<
  59. value_type
  60. , std::priority_queue<
  61. value_type
  62. , std::vector<value_type>
  63. , less
  64. >
  65. , pqueue_traits
  66. > pqueue_type;
  67. pqueue_type pq;
  68. test( pq );
  69. }
  70. TEST_F( FCPQueue, vector_stat_single_mutex_multi_condvar )
  71. {
  72. struct pqueue_traits : public cds::container::fcpqueue::traits
  73. {
  74. typedef cds::container::fcpqueue::stat<> stat;
  75. typedef cds::algo::flat_combining::wait_strategy::single_mutex_multi_condvar<42> wait_strategy;
  76. };
  77. typedef cds::container::FCPriorityQueue<
  78. value_type
  79. , std::priority_queue<
  80. value_type
  81. , std::vector<value_type>
  82. , less
  83. >
  84. , pqueue_traits
  85. > pqueue_type;
  86. pqueue_type pq;
  87. test( pq );
  88. }
  89. TEST_F( FCPQueue, vector_mutex )
  90. {
  91. typedef cds::container::FCPriorityQueue<
  92. value_type
  93. ,std::priority_queue< value_type >
  94. ,cds::container::fcpqueue::make_traits<
  95. cds::opt::lock_type< std::mutex >
  96. >::type
  97. > pqueue_type;
  98. pqueue_type pq;
  99. test( pq );
  100. }
  101. TEST_F( FCPQueue, vector_single_mutex_single_condvar )
  102. {
  103. typedef cds::container::FCPriorityQueue<
  104. value_type
  105. ,std::priority_queue< value_type >
  106. ,cds::container::fcpqueue::make_traits<
  107. cds::opt::lock_type< std::mutex >
  108. , cds::opt::wait_strategy< cds::algo::flat_combining::wait_strategy::single_mutex_single_condvar<1000>>
  109. >::type
  110. > pqueue_type;
  111. pqueue_type pq;
  112. test( pq );
  113. }
  114. } // namespace cds_test