diff options
author | Rasmus Munk Larsen <rmlarsen@google.com> | 2020-12-02 11:04:04 -0800 |
---|---|---|
committer | Rasmus Munk Larsen <rmlarsen@google.com> | 2020-12-02 11:04:04 -0800 |
commit | 71c85df4c1ce4efa41bb4adc8e9cb224c3ca9a2d (patch) | |
tree | c0f768dccd1dbca1fe17621bf8638c9102b8f170 /unsupported/test | |
parent | 70fbcf82ed0a95b27ee68e20199a4e8e1e913268 (diff) |
Clean up the Tensor header and get rid of the EIGEN_SLEEP macro.
Diffstat (limited to 'unsupported/test')
-rw-r--r-- | unsupported/test/cxx11_non_blocking_thread_pool.cpp | 4 | ||||
-rw-r--r-- | unsupported/test/cxx11_tensor_notification.cpp | 8 |
2 files changed, 7 insertions, 5 deletions
diff --git a/unsupported/test/cxx11_non_blocking_thread_pool.cpp b/unsupported/test/cxx11_non_blocking_thread_pool.cpp index 90b330fdc..993ee1789 100644 --- a/unsupported/test/cxx11_non_blocking_thread_pool.cpp +++ b/unsupported/test/cxx11_non_blocking_thread_pool.cpp @@ -109,7 +109,9 @@ static void test_cancel() // Schedule a large number of closure that each sleeps for one second. This // will keep the thread pool busy for much longer than the default test timeout. for (int i = 0; i < 1000; ++i) { - tp.Schedule([]() { EIGEN_SLEEP(2000); }); + tp.Schedule([]() { + std::this_thread::sleep_for(std::chrono::milliseconds(2000)); + }); } // Cancel the processing of all the closures that are still pending. diff --git a/unsupported/test/cxx11_tensor_notification.cpp b/unsupported/test/cxx11_tensor_notification.cpp index 2bade8dc7..8e8165302 100644 --- a/unsupported/test/cxx11_tensor_notification.cpp +++ b/unsupported/test/cxx11_tensor_notification.cpp @@ -23,7 +23,7 @@ static void test_notification_single() Eigen::Notification n; auto func = [&n, &counter](){ n.Wait(); ++counter;}; thread_pool.Schedule(func); - EIGEN_SLEEP(1000); + std::this_thread::sleep_for(std::chrono::milliseconds(1000)); // The thread should be waiting for the notification. VERIFY_IS_EQUAL(counter, 0); @@ -31,7 +31,7 @@ static void test_notification_single() // Unblock the thread n.Notify(); - EIGEN_SLEEP(1000); + std::this_thread::sleep_for(std::chrono::milliseconds(1000)); // Verify the counter has been incremented VERIFY_IS_EQUAL(counter, 1); @@ -50,10 +50,10 @@ static void test_notification_multiple() thread_pool.Schedule(func); thread_pool.Schedule(func); thread_pool.Schedule(func); - EIGEN_SLEEP(1000); + std::this_thread::sleep_for(std::chrono::milliseconds(1000)); VERIFY_IS_EQUAL(counter, 0); n.Notify(); - EIGEN_SLEEP(1000); + std::this_thread::sleep_for(std::chrono::milliseconds(1000)); VERIFY_IS_EQUAL(counter, 4); } |