fix timer causing not able to ctrl-c exit without all timer ending

.gitignore

@@ -1,3 +1,10 @@
 build/
 .vscode
 .cache
+CMakeCache.txt
+CMakeFiles
+cmake_install.cmake
+Makefile
+install_manifest.txt
+CMakeLists.txt.user
+ninjia.build

examples/CMakeLists.txt

@@ -5,4 +5,7 @@ add_executable(gnunetpp-fs fs/main.cpp)
 target_link_libraries(gnunetpp-fs gnunetfs gnunetcore gnunetidentity gnunetutil gnunetpp)
 
 add_executable(gnunetpp-identity identity/main.cpp)
-target_link_libraries(gnunetpp-identity gnunetidentity gnunetcore gnunetutil gnunetpp)
+target_link_libraries(gnunetpp-identity gnunetidentity gnunetcore gnunetutil gnunetpp)
+
+add_executable(gnunetpp-scheduler scheduler/main.cpp)
+target_link_libraries(gnunetpp-scheduler gnunetcore gnunetutil gnunetpp)

examples/scheduler/main.cpp

@@ -0,0 +1,15 @@
+#include <gnunetpp.hpp>
+#include <iostream>
+
+void service(const GNUNET_CONFIGURATION_Handle* cfg)
+{
+    std::cout << "Hello world will be printed in 5 seconds" << std::endl;
+    gnunetpp::scheduler::runLater(std::chrono::seconds(5), []() {
+        std::cout << "Hello, world!" << std::endl;
+    });
+}
+
+int main()
+{
+    gnunetpp::run(service);
+}

gnunetpp/gnunetpp-scheduler.cpp

@@ -84,11 +84,20 @@ void cancel(TaskID id)
     g_tasks.remove(id);
 }
 
+void cancelAll()
+{
+    for(auto& [id, data] : g_tasks)
+        GNUNET_SCHEDULER_cancel(data.handle);
+    g_tasks.clear();
+}
+
 static bool running = true;
 void shutdown()
 {
-    if(running)
+    if(running) {
+        cancelAll();
         GNUNET_SCHEDULER_shutdown();
+    }
     running = false;
 }
 

gnunetpp/gnunetpp-scheduler.hpp

@@ -15,5 +15,6 @@ TaskID runEvery(std::chrono::duration<double> delay, std::function<void()> fn);
 void runOnShutdown(std::function<void()> fn);
 void run(std::function<void()> fn);
 void cancel(TaskID id);
+void cancelAll();
 void shutdown();
 }

gnunetpp/inner/UniqueData.hpp

@@ -44,8 +44,34 @@ struct UniqueData
 
     bool contains(size_t id)
     {
-	std::lock_guard l(mtx);
-	return data.find(id) != data.end();
+        std::lock_guard l(mtx);
+        return data.find(id) != data.end();
+    }
+
+    auto begin()
+    {
+        return data.begin();
+    }
+
+    auto end()
+    {
+        return data.end();
+    }
+
+    auto begin() const
+    {
+        return data.begin();
+    }
+
+    auto end() const
+    {
+        return data.end();
+    }
+
+    void clear()
+    {
+        std::lock_guard l(mtx);
+        data.clear();
     }
 protected:
     std::mutex mtx;