Test with threads

Author: krzysg

examples/Example_get_apr.cpp

@@ -38,13 +38,11 @@ Advanced (Direct) Settings:
 #include "ConfigAPR.h"
 #include "Example_get_apr.h"
 
-int main(int argc, char **argv) {
-
-    //input parsing
-    cmdLineOptions options;
+#include <future>
+#include <thread>
 
-    options = read_command_line_options(argc,argv);
 
+int runAPR(cmdLineOptions options) {
     //the apr datastructure
     APR<uint16_t> apr;
 
@@ -144,10 +142,34 @@ int main(int argc, char **argv) {
         std::cout << "Oops, something went wrong. APR not computed :(." << std::endl;
     }
     return 0;
+}
+
+
+int main(int argc, char **argv) {
+
+    //input parsing
+    cmdLineOptions options;
 
+    options = read_command_line_options(argc, argv);
+    std::vector<std::future<int>> fv;
+    fv.emplace_back(std::async(std::launch::async, [=]{ return runAPR(options); }));
+    fv.emplace_back(std::async(std::launch::async, [=]{ return runAPR(options); }));
+    fv.emplace_back(std::async(std::launch::async, [=]{ return runAPR(options); }));
+    int n = 3;
+    std::cout << "Waintig..." <<std::endl;
+    for (int i = 0; i < fv.size()*3; ++i) {
+        fv[i % n].wait();
+        fv[i % n] = std::async(std::launch::async, [=]{ return runAPR(options); });
+    }
+
+    for (int i = 0; i < fv.size(); ++i) fv[i].wait();
+    
+    std::cout << "DONE!" <<std::endl;
+    return fv[0].get();
 }
 
 
+
 bool command_option_exists(char **begin, char **end, const std::string &option)
 {
     return std::find(begin, end, option) != end;

src/algorithm/APRConverter.hpp

@@ -235,18 +235,7 @@ inline bool APRConverter<ImageType>::get_apr_method(APR<ImageType> &aAPR, PixelD
     t.start_timer(" =========== ALL");
     {
         GpuProcessingTask<ImageType> gpt1(image_temp, local_scale_temp, par, bspline_offset, (*apr).level_max());
-        GpuProcessingTask<ImageType> gpt2(image_temp, local_scale_temp, par, bspline_offset, (*apr).level_max());
-        GpuProcessingTask<ImageType> gpt3(image_temp, local_scale_temp, par, bspline_offset, (*apr).level_max());
-        GpuProcessingTask<ImageType> gpt4(image_temp, local_scale_temp, par, bspline_offset, (*apr).level_max());
-        for (int i = 0; i < 2; ++i) {
-            gpt1.doAll();
-            gpt2.doAll();
-            gpt3.doAll();
-            gpt4.doAll();
-//        gpt3.sendDataToGpu();
-//        gpt3.processOnGpu();
-//        gpt3.getDataFromGpu();
-        }
+        gpt1.doAll();
     }
     t.stop_timer();
     method_timer.stop_timer();