From: Timo Heister <timo.heister@gmail.com>
Date: Thu, 28 May 2020 19:16:30 +0000 (-0400)
Subject: add cpp-taskflow quicktest
X-Git-Tag: v9.3.0-rc1~1488^2~2
X-Git-Url: https://gitweb.dealii.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=51c64479f5fa0453bc1d3aef51e15cbb57cf33aa;p=dealii.git

add cpp-taskflow quicktest
---

diff --git a/tests/quick_tests/CMakeLists.txt b/tests/quick_tests/CMakeLists.txt
index 774b17709c..69d08dafc3 100644
--- a/tests/quick_tests/CMakeLists.txt
+++ b/tests/quick_tests/CMakeLists.txt
@@ -102,10 +102,15 @@ IF (DEAL_II_WITH_MPI)
 ENDIF()
 
 # Test if TBB works correctly
-IF (DEAL_II_WITH_THREADS)
+IF (DEAL_II_WITH_TBB)
   make_quicktest("tbb" ${_mybuild} "")
 ENDIF()
 
+# test cpp-taskflow
+IF (DEAL_II_WITH_CPP_TASKFLOW)
+  make_quicktest("taskflow" ${_mybuild} "")
+ENDIF()
+
 # Test p4est. This test exposes a bug in OpenMPI 1.3 and 1.4
 # Update to OpenMPI 1.5 or newer.
 IF (DEAL_II_WITH_P4EST)
diff --git a/tests/quick_tests/taskflow.cc b/tests/quick_tests/taskflow.cc
new file mode 100644
index 0000000000..25747b529f
--- /dev/null
+++ b/tests/quick_tests/taskflow.cc
@@ -0,0 +1,83 @@
+// ---------------------------------------------------------------------
+//
+// Copyright (C) 2020 by the deal.II authors
+//
+// This file is part of the deal.II library.
+//
+// The deal.II library is free software; you can use it, redistribute
+// it, and/or modify it under the terms of the GNU Lesser General
+// Public License as published by the Free Software Foundation; either
+// version 2.1 of the License, or (at your option) any later version.
+// The full text of the license can be found in the file LICENSE.md at
+// the top level directory of deal.II.
+//
+// ---------------------------------------------------------------------
+
+// test cpp-taskflow
+
+#include <deal.II/base/thread_management.h>
+
+DEAL_II_DISABLE_EXTRA_DIAGNOSTICS
+#include <taskflow/taskflow.hpp>
+DEAL_II_ENABLE_EXTRA_DIAGNOSTICS
+
+#include <iostream>
+
+using namespace dealii;
+
+void
+test1()
+{
+  auto &executor = MultithreadInfo::get_taskflow_executor();
+
+  std::atomic<unsigned int> counter;
+  counter = 0;
+
+  tf::Taskflow taskflow;
+
+  auto incrementor = [&]() { counter.fetch_add(1); };
+
+
+  tf::Task A = taskflow.emplace(incrementor);
+  tf::Task B = taskflow.emplace(incrementor);
+  tf::Task C = taskflow.emplace([&]() {
+    std::cout << "counter = " << counter << std::endl;
+    counter = 0;
+  });
+
+  A.precede(C);
+  B.precede(C);
+
+  auto p =
+    taskflow.parallel_for(1, 11, 1, [&](int idx) { counter.fetch_add(idx); });
+
+  C.precede(p.first);
+
+  executor.run(taskflow).wait();
+
+  if (counter != 55)
+    {
+      std::cout << "error: counter is " << counter << " and not 55."
+                << std::endl;
+      exit(1);
+    }
+
+  taskflow.dump(std::cout);
+}
+
+
+
+int
+main()
+{
+  MultithreadInfo::set_thread_limit();
+
+  std::cout << "cpp-taskflow will use "
+            << MultithreadInfo::get_taskflow_executor().num_workers()
+            << " out of " << MultithreadInfo::n_cores() << " cores."
+            << std::endl
+            << "MultithreadInfo::n_thread()= " << MultithreadInfo::n_threads()
+            << std::endl;
+
+  test1();
+}