exclude pool tests from miri tests

Author: orxfun

README.md

@@ -525,6 +525,7 @@ let sum = inputs.par().sum();
     assert_eq!(sum, sum2);
 }
 
+#[cfg(not(miri))]
 #[cfg(feature = "scoped_threadpool")]
 {
     let mut pool = scoped_threadpool::Pool::new(8);
@@ -533,6 +534,7 @@ let sum = inputs.par().sum();
     assert_eq!(sum, sum2);
 }
 
+#[cfg(not(miri))]
 #[cfg(feature = "rayon-core")]
 {
     let pool = rayon_core::ThreadPoolBuilder::new()
@@ -544,6 +546,7 @@ let sum = inputs.par().sum();
     assert_eq!(sum, sum2);
 }
 
+#[cfg(not(miri))]
 #[cfg(feature = "yastl")]
 {
     let pool = YastlPool::new(8);

src/par_iter.rs

@@ -286,6 +286,7 @@ where
     ///     assert_eq!(sum, sum2);
     /// }
     ///
+    /// #[cfg(not(miri))]
     /// #[cfg(feature = "scoped_threadpool")]
     /// {
     ///     let mut pool = scoped_threadpool::Pool::new(8);
@@ -295,6 +296,7 @@ where
     ///     assert_eq!(sum, sum2);
     /// }
     ///
+    /// #[cfg(not(miri))]
     /// #[cfg(feature = "rayon-core")]
     /// {
     ///     let pool = rayon_core::ThreadPoolBuilder::new()
@@ -354,6 +356,7 @@ where
     ///     assert_eq!(sum, sum2);
     /// }
     ///
+    /// #[cfg(not(miri))]
     /// #[cfg(feature = "scoped_threadpool")]
     /// {
     ///     let mut pool = scoped_threadpool::Pool::new(8);
@@ -363,6 +366,7 @@ where
     ///     assert_eq!(sum, sum2);
     /// }
     ///
+    /// #[cfg(not(miri))]
     /// #[cfg(feature = "rayon-core")]
     /// {
     ///     let pool = rayon_core::ThreadPoolBuilder::new()

src/par_thread_pool.rs

@@ -40,6 +40,7 @@ use orx_concurrent_bag::ConcurrentBag;
 /// ```
 /// use orx_parallel::*;
 ///
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "rayon-core")]
 /// {
 ///     let pool = rayon::ThreadPoolBuilder::new()
@@ -72,6 +73,7 @@ use orx_concurrent_bag::ConcurrentBag;
 /// ```
 /// use orx_parallel::*;
 ///
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "scoped_threadpool")]
 /// {
 ///     // creating a runner for the computation

src/runner/implementations/runner_with_pool.rs

@@ -46,6 +46,7 @@ use core::marker::PhantomData;
 /// }
 ///
 /// // uses rayon-core ThreadPool with 8 threads
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "rayon-core")]
 /// {
 ///     let pool = rayon_core::ThreadPoolBuilder::new()
@@ -57,6 +58,7 @@ use core::marker::PhantomData;
 /// }
 ///
 /// // uses scoped-pool Pool with 8 threads
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "scoped-pool")]
 /// {
 ///     let pool = scoped_pool::Pool::new(8);
@@ -65,6 +67,7 @@ use core::marker::PhantomData;
 /// }
 ///
 /// // uses scoped_threadpool Pool with 8 threads
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "scoped_threadpool")]
 /// {
 ///     let mut pool = scoped_threadpool::Pool::new(8);
@@ -73,6 +76,7 @@ use core::marker::PhantomData;
 /// }
 ///
 /// // uses yastl Pool wrapped as YastlPool with 8 threads
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "yastl")]
 /// {
 ///     let pool = YastlPool::new(8);
@@ -81,6 +85,7 @@ use core::marker::PhantomData;
 /// }
 ///
 /// // uses pond Pool wrapped as PondPool with 8 threads
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "pond")]
 /// {
 ///     let mut pool = PondPool::new_threads_unbounded(8);
@@ -89,6 +94,7 @@ use core::marker::PhantomData;
 /// }
 ///
 /// // uses poolite Pool with 8 threads
+/// #[cfg(not(miri))]
 /// #[cfg(feature = "poolite")]
 /// {
 ///     let pool = poolite::Pool::with_builder(poolite::Builder::new().min(8).max(8)).unwrap();
@@ -153,6 +159,7 @@ where
     /// let vec: Vec<_> = (0..42).collect();
     /// let input = vec.as_slice();
     ///
+    /// #[cfg(not(miri))]
     /// #[cfg(feature = "rayon-core")]
     /// {
     ///     let pool = rayon_core::ThreadPoolBuilder::new()

src/runner/implementations/tests/pond.rs

@@ -10,6 +10,8 @@ const N: [usize; 2] = [37, 125];
 #[cfg(not(miri))]
 const N: [usize; 2] = [1025, 4735];
 
+// TODO: miri test terminates with: the main thread terminated without waiting for all remaining threads
+#[cfg(not(miri))]
 #[test_matrix(
     [0, 1, N[0], N[1]],
     [1, 4],

src/runner/implementations/tests/scoped_threadpool.rs

@@ -8,6 +8,8 @@ const N: [usize; 2] = [37, 125];
 #[cfg(not(miri))]
 const N: [usize; 2] = [1025, 4735];
 
+// TODO: miri test terminates with: the main thread terminated without waiting for all remaining threads
+#[cfg(not(miri))]
 #[test_matrix(
     [0, 1, N[0], N[1]],
     [1, 4],

src/runner/implementations/tests/yastl.rs

@@ -11,6 +11,8 @@ const N: [usize; 2] = [37, 125];
 #[cfg(not(miri))]
 const N: [usize; 2] = [1025, 4735];
 
+// TODO: miri test terminates with: the main thread terminated without waiting for all remaining threads
+#[cfg(not(miri))]
 #[test_matrix(
     [0, 1, N[0], N[1]],
     [1, 4],