Added allocator example

CMakeLists.txt

@@ -17,7 +17,7 @@ project(hpx_kokkos_example)
 set(CMAKE_CXX_STANDARD 14)
 set(CMAKE_CXX_STANDARD_REQUIRED ON)
 set(CMAKE_CXX_EXTENSIONS OFF)
-set(SKIP_HPX_KOKKOS_BUILD False)
+set(SKIP_HPX_KOKKOS_BUILD TRUE)
 
 #================================================================================================================================================
 # Setup HPX
@@ -128,5 +128,13 @@ link_libraries(kokkos hpx dl boost_system boost_program_options boost_thread boo
 
 add_hpx_executable(hello SOURCES ${SOURCES})
 
+add_hpx_executable(
+	allocator_test
+	SOURCES
+		${CMAKE_CURRENT_SOURCE_DIR}/src/allocator_test.cpp 
+	HEADERS 
+		${CMAKE_CURRENT_SOURCE_DIR}/include/buffer_manager.hpp
+)
+
 add_compile_options(-I${CMAKE_CURRENT_SOURCE_DIR}/external_dependencies/kokkos-hpx-interop/include)
 add_hpx_executable(interop SOURCES ${CMAKE_CURRENT_SOURCE_DIR}/external_dependencies/kokkos-hpx-interop/src/kokkos_hpx.cpp)

include/buffer_manager.hpp

@@ -0,0 +1,55 @@
+// TODO Insert Allocator
+
+// TODO Insert singleton memory mananger -> Wird der überhaupt benötigt?
+// Vermutlich hauptsächlich um callbacks zu verwalten und die Synchronisierung zu machen
+#include <iostream>
+
+
+class buffer_recycler {
+  public:
+    template <class T>
+    static void get(size_t number_elements) {
+      if (!instance)
+        instance = new buffer_recycler();
+        buffer_manager<T>::get(number_elements);
+    }
+    static void clean(void) {
+      if (instance)
+        delete instance;
+    }
+  private: 
+    static buffer_recycler *instance;
+    buffer_recycler(void) {
+      std::cout << "Buffer recycler constructor!" << std::endl;
+    }
+    ~buffer_recycler(void) {
+      std::cout << "Buffer recycler destructor!" << std::endl;
+    }
+
+  private: 
+    template<class T>
+    class buffer_manager {
+      public:
+        static void get(size_t number_elements) {
+        if (!instance)
+            instance = new buffer_manager();
+        }
+
+      private:
+        std::list<T*> buffer_list;
+        static buffer_manager<T> *instance; // requires C++17
+
+        buffer_manager(void) {
+        std::cout << "Buffer mananger constructor for " << typeid(T).name() << std::endl;
+        }
+        ~buffer_manager(void) {
+        std::cout << "Buffer mananger destructor for " << typeid(T).name() << std::endl;
+        }
+    };
+};
+
+// Instance defintions
+buffer_recycler* buffer_recycler::instance = nullptr;
+
+template<class T>
+buffer_recycler::buffer_manager<T>* buffer_recycler::buffer_manager<T>::instance = nullptr; 

src/allocator_test.cpp

@@ -0,0 +1,24 @@
+#include <hpx/hpx_main.hpp> // we don't need an hpx_main that way?
+#include <hpx/include/async.hpp>
+#include <hpx/include/lcos.hpp>
+
+#include "../include/buffer_manager.hpp"
+#include <cstdio>
+#include <typeinfo>
+
+
+// TODO Insert templated singleton submanager -> Eine Bufferliste pro Submanager. Ein Buffer is
+// Do it is as subclass
+
+// #pragma nv_exec_check_disable
+int main(int argc, char *argv[])
+{
+  buffer_recycler::get<double>(1000);
+  buffer_recycler::get<double>(1000);
+  buffer_recycler::get<int>(1000);
+  buffer_recycler::get<int>(1000);
+  std::cout << std::endl;
+  // Create Vectors with the new allocator
+
+  buffer_recycler::clean();
+}

src/hello.cpp

@@ -275,25 +275,4 @@ int main(int argc, char *argv[])
     auto when = hpx::when_all(f, g, h, i, j, k, l);
     when.wait();
   }
-
-  // // Kokkos hello world example
-  // {
-  //   std::size_t worker_id = hpx::get_worker_thread_num();
-  //   std::size_t locality_id = hpx::get_locality_id();
-
-  //   printf("HPX Thread %i on Locality %i\n\n", worker_id, locality_id);
-
-  //   Kokkos::parallel_for("HelloWorld", Kokkos::RangePolicy<Kokkos::Cuda>(0, 14), hello_world());
-  //   Kokkos::fence();
-
-  //   printf("Hello World on Kokkos execution space %s\n",
-  //          typeid(Kokkos::Experimental::HPX).name());
-  //   Kokkos::parallel_for("HelloWorld", Kokkos::RangePolicy<Kokkos::Experimental::HPX>(0, 14), hello_world());
-  //   Kokkos::fence();
-
-  //   printf("Hello World on Kokkos execution space %s\n",
-  //          typeid(Kokkos::Serial).name());
-  //   Kokkos::parallel_for("HelloWorld", Kokkos::RangePolicy<Kokkos::Serial>(0, 14), hello_world());
-  //   Kokkos::fence();
-  // }
 }