Launch deferred #21 (#23)

* #21 adding std::launch option when adding tasks and a execute_deferred() function to executed tasks queued as deferred * #21 changed name from evaluate_deferred to invoke_deferred and added minimal test * 🎨 Committing clang-format changes * #21 Trying to adjust for failing tests on apple-clang * #21 increasing test coverage * #21 Correcting some tests that got locked up * 🎨 Committing clang-format changes * #24 corrected race condition * #21 doesnt like magic numbers * Corrected timedecrement in tests * #21 * 🎨 Committing clang-format changes * 🎨 Committing clang-format changes * 🎨 Committing clang-format changes --------- Co-authored-by: Clang Robot <robot@example.com>
benny-edlund · Sep 16, 2023 · 06dc1c2 · 06dc1c2
1 parent cfed231
commit 06dc1c2
Show file tree

Hide file tree

Showing 3 changed files with 462 additions and 306 deletions.
diff --git a/lib/public/task_pool/pipes.h b/lib/public/task_pool/pipes.h
@@ -1,5 +1,6 @@
 #pragma once
 #include <chrono>
+#include <future>
 #include <task_pool/fallbacks.h>
 #include <task_pool/pool.h>
 #include <task_pool/traits.h>
@@ -28,7 +29,9 @@ TASKPOOL_HIDDEN auto make_pipe( be::task_pool_t< Allocator >& pool, Func&& func,
         // are most certainly used in the defined class
         //
         using future_type    = decltype( std::declval< be::task_pool_t< Allocator > >().submit(
-            std::declval< Func >(), std::forward< Args >( std::declval< Args >() )... ) );
+            std::launch::async,
+            std::declval< Func >(),
+            std::forward< Args >( std::declval< Args >() )... ) );
         using value_type     = decltype( std::declval< future_type >().get() );
         using status_type    = decltype( std::declval< future_type >().wait_for(
             std::declval< std::chrono::seconds >() ) );
@@ -72,7 +75,9 @@ TASKPOOL_HIDDEN auto make_pipe( be::task_pool_t< Allocator >& pool, Func&& func,
         }
     };
     return pipe_( pool,
-                  pool.submit( std::forward< Func >( func ), std::forward< Args >( args )... ) );
+                  pool.submit( std::launch::async,
+                               std::forward< Func >( func ),
+                               std::forward< Args >( args )... ) );
 }
 
 template< typename TaskPool,