Use std::future over std::thread for background jobsHEADmain

Easier checking if a job has completed [successfully] and reseting state
for the next time.

2 files changed, 10 insertions, 5 deletions

diff --git a/src/ingestor.cpp b/src/ingestor.cpp
index ba89991..692ddd2 100644
--- a/src/ingestor.cpp
+++ b/src/ingestor.cpp
@@ -223,17 +223,21 @@ namespace WebStat {
 	Ingestor::runJobsAsNeeded()
 	{
 		auto runJobAsNeeded = [this, now = Job::LastRunTime::clock::now()](Job & job, auto freq) {
-			if (!job.currentRun && expired(job.lastRun, freq, now)) {
-				job.currentRun.emplace([this, now, freq, &job]() {
+			if (job.currentRun) {
+				if (job.currentRun->valid()) {
 					try {
-						(this->*job.impl)();
+						job.currentRun->get();
 						job.lastRun = now;
 					}
 					catch (const std::exception &) {
 						// Error, retry in half the frequency
 						job.lastRun = now - (freq / 2);
 					}
-				});
+					job.currentRun.reset();
+				}
+			}
+			else if (expired(job.lastRun, freq, now)) {
+				job.currentRun.emplace(std::async(job.impl, this));
 			}
 		};
 		runJobAsNeeded(ingestParkedLines, settings.freqIngestParkedLines);
diff --git a/src/ingestor.hpp b/src/ingestor.hpp
index c5628d6..0bf2297 100644
--- a/src/ingestor.hpp
+++ b/src/ingestor.hpp
@@ -8,6 +8,7 @@
 #include <connection_fwd.h>
 #include <cstdio>
 #include <flat_set>
+#include <future>
 #include <scn/scan.h>
 #include <span>
 #include <sys/utsname.h>
@@ -78,7 +79,7 @@ namespace WebStat {
 
 			const Impl impl;
 			LastRunTime lastRun {LastRunTime::clock::now()};
-			std::optional<std::thread> currentRun {std::nullopt};
+			std::optional<std::future<unsigned int>> currentRun;
 		};
 
 		Job::LastRunTime lastCheckedJobs {Job::LastRunTime::clock::now()};