Apply clang-format to rnd_future_reduce.cpp

Signed-off-by: Vaibhav Joshi <joshivaibhav553@gmail.com>

Author: vaibhavj2006

examples/future_reduce/rnd_future_reduce.cpp

@@ -9,6 +9,7 @@
 #include <hpx/init.hpp>
 #include <hpx/runtime.hpp>
 //
+#include <cmath>
 #include <iostream>
 #include <random>
 #include <utility>
@@ -22,20 +23,20 @@
 // any fail = !pass rule, then this example shows how to do it.
 // The user can experiment with the failure rate to see if the statistics match
 // their expectations.
-// Also. Routine can use either a lambda, or a function under control of USE_LAMBDA
+// Al
 
-#define TEST_SUCCESS 1
-#define TEST_FAIL 0
+constexpr int TEST_SUCCESS = 1;
+constexpr int TEST_FAIL = 0;
 //
-#define FAILURE_RATE_PERCENT 5
-#define SAMPLES_PER_LOOP 10
-#define TEST_LOOPS 1000
+constexpr int FAILURE_RATE_PERCENT = 0;
+constexpr int SAMPLES_PER_LOOP = 10;
+constexpr int TEST_LOOPS = 1000;
 //
-std::random_device rseed;
-std::mt19937 gen(rseed());
-std::uniform_int_distribution<int> dist(0, 99);    // interval [0,100)
+constexpr unsigned SEED = 42u;
+static std::mt19937 gen(SEED);
+static std::uniform_int_distribution<int> dist(0, 99);    // interval [0,100)
 
-#define USE_LAMBDA
+constexpr bool USE_LAMBDA = true;
 
 //----------------------------------------------------------------------------
 int reduce(hpx::future<std::vector<hpx::future<int>>>&& futvec)
@@ -67,34 +68,37 @@ hpx::future<int> test_reduce()
 {
     std::vector<hpx::future<int>> req_futures;
     //
-    for (int i = 0; i < SAMPLES_PER_LOOP; i++)
+    for (int i = 0; i < SAMPLES_PER_LOOP; ++i)
     {
-        // generate random sequence of pass/fails using % fail rate per incident
-        hpx::future<int> result = hpx::async(generate_one);
-        req_futures.push_back(std::move(result));
+        req_futures.push_back(hpx::async(&generate_one));
     }
 
     hpx::future<std::vector<hpx::future<int>>> all_ready =
         hpx::when_all(req_futures);
 
-#ifdef USE_LAMBDA
-    hpx::future<int> result = all_ready.then(
-        [](hpx::future<std::vector<hpx::future<int>>>&& futvec) -> int {
-            // futvec is ready or the lambda would not be called
-            std::vector<hpx::future<int>> vfs = futvec.get();
-            // all futures in v are ready as fut is ready
-            int res = TEST_SUCCESS;
-            for (hpx::future<int>& f : vfs)
-            {
-                if (f.get() == TEST_FAIL)
-                    return TEST_FAIL;
-            }
-            return res;
-        });
-#else
-    hpx::future<int> result = all_ready.then(reduce);
-#endif
-    //
+    hpx::future<int> result;
+    if constexpr (USE_LAMBDA)
+    {
+        result = all_ready.then(
+            [](hpx::future<std::vector<hpx::future<int>>>&& futvec) -> int {
+                std::vector<hpx::future<int>> vfs = futvec.get();
+                int res = TEST_SUCCESS;
+
+                hpx::wait_each(
+                    [&res](hpx::future<int> f) {
+                        if (f.get() == TEST_FAIL)
+                            res = TEST_FAIL;
+                    },
+                    vfs);
+
+                return res;
+            });
+    }
+    else
+    {
+        result = all_ready.then(reduce);
+    }
+
     return result;
 }
 
@@ -104,18 +108,20 @@ int hpx_main()
     hpx::chrono::high_resolution_timer htimer;
     // run N times and see if we get approximately the right amount of fails
     int count = 0;
-    for (int i = 0; i < TEST_LOOPS; i++)
+    for (int i = 0; i < TEST_LOOPS; ++i)
     {
         int result = test_reduce().get();
         count += result;
     }
+
     double pr_pass =
         std::pow(1.0 - FAILURE_RATE_PERCENT / 100.0, SAMPLES_PER_LOOP);
     double exp_pass = TEST_LOOPS * pr_pass;
-    std::cout << "From " << TEST_LOOPS << " tests, we got "
-              << "\n " << count << " passes"
-              << "\n " << exp_pass << " expected \n"
-              << "\n " << htimer.elapsed() << " seconds \n"
+
+    std::cout << "From " << TEST_LOOPS << " tests, we got\n"
+              << " " << count << " passes\n"
+              << " " << exp_pass << " expected\n\n"
+              << "Elapsed: " << htimer.elapsed() << " seconds\n"
               << std::flush;
     // Initiate shutdown of the runtime system.
     return hpx::local::finalize();