From ac694dcd7b8233e8797be8f82ae850b6eae04edb Mon Sep 17 00:00:00 2001
From: iysheng <iysheng@163.com>
Date: Mon, 21 Nov 2022 15:44:42 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AD=90=E7=BA=BF?=
 =?UTF-8?q?=E7=A8=8B=E5=9B=9E=E8=B0=83=E5=87=BD=E6=95=B0=E6=94=AF=E6=8C=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 include/cron_timer.h | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/include/cron_timer.h b/include/cron_timer.h
index 5977190..c28548b 100644
--- a/include/cron_timer.h
+++ b/include/cron_timer.h
@@ -424,6 +424,10 @@ class TimerMgr {
 
 public:
 	TimerMgr() {}
+	TimerMgr(FUNC_CALLBACK&& func){
+		std::thread subthread(func);
+		subthread.detach();
+	}
 	TimerMgr(const TimerMgr&) = delete;
 	const TimerMgr& operator=(const TimerMgr&) = delete;
 

From ed2012203d296b6d208a84048b11ee26158b3217 Mon Sep 17 00:00:00 2001
From: iysheng <iysheng@163.com>
Date: Mon, 21 Nov 2022 19:44:35 +0800
Subject: [PATCH 2/2] =?UTF-8?q?1.=20=E5=A4=9A=E7=BA=BF=E7=A8=8B=E6=97=B6?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=B8=B4=E7=95=8C=E5=8C=BA=E4=BF=9D=E6=8A=A4?=
 =?UTF-8?q?=202.=20=E6=B7=BB=E5=8A=A0=E5=AD=90=E7=BA=BF=E7=A8=8B=E4=BE=8B?=
 =?UTF-8?q?=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 example/main.cpp     | 69 ++++++++++++++++++++++++++++++++++++++++++++
 include/cron_timer.h |  9 ++++++
 2 files changed, 78 insertions(+)

diff --git a/example/main.cpp b/example/main.cpp
index aa04160..9972741 100644
--- a/example/main.cpp
+++ b/example/main.cpp
@@ -15,6 +15,8 @@
 
 std::atomic_bool _shutDown;
 
+#define TEST_IN_SUBTHREAD
+
 #ifdef _WIN32
 BOOL WINAPI ConsoleHandler(DWORD CtrlType) {
 	switch (CtrlType) {
@@ -144,6 +146,69 @@ void TestCronTimerInMainThread() {
 	}
 }
 
+#ifdef TEST_IN_SUBTHREAD
+void TestCronTimerInSubThread() {
+	// 如果你想在子线程中触发定时器事件
+	std::shared_ptr<cron_timer::TimerMgr> mgr = std::make_shared<cron_timer::TimerMgr>([&]() {
+		if (!mgr)
+			return;
+		while(!mgr->MultiThreadsReady());
+		while (1) {
+			// 在子线程中触发定时器事件
+			mgr->Update();
+		}
+	});
+
+	mgr->AddTimer("* * * * * *", [](void) {
+		// 每秒钟都会执行一次
+		Log("1 second cron timer hit");
+	});
+
+	mgr->AddTimer("0/3 * * * * *", [](void) {
+		// 从0秒开始，每3秒钟执行一次
+		Log("3 second cron timer hit");
+	});
+
+	mgr->AddTimer("0 * * * * *", [](void) {
+		// 1分钟执行一次（每次都在0秒的时候执行）的定时器
+		Log("1 minute cron timer hit");
+	});
+
+	mgr->AddTimer("15;30;33 * * * * *", [](void) {
+		// 指定时间（15秒、30秒和33秒）点都会执行一次
+		Log("cron timer hit at 15s or 30s or 33s");
+	});
+
+	mgr->AddTimer("40-50 * * * * *", [](void) {
+		// 指定时间段（40到50内的每一秒）执行的定时器
+		Log("cron timer hit between 40s to 50s");
+	});
+
+	std::weak_ptr<cron_timer::BaseTimer> timer = mgr->AddDelayTimer(3000, [](void) {
+		// 3秒钟之后执行
+		Log("3 second delay timer hit");
+	});
+
+	// 可以在执行之前取消
+	if (auto ptr = timer.lock(); ptr != nullptr) {
+		ptr->Cancel();
+	}
+
+	mgr->AddDelayTimer(
+		10000,
+		[](void) {
+			// 每10秒钟执行一次，总共执行3次
+			Log("10 second delay timer hit");
+		},
+		3);
+	mgr->MarkMultiThreadsReady(true);
+	Log("10 second delay timer added");
+	while (!_shutDown) {
+		std::this_thread::sleep_for(std::chrono::milliseconds(100));
+	}
+}
+#endif
+
 int main() {
 #ifdef _WIN32
 	SetConsoleCtrlHandler(ConsoleHandler, TRUE);
@@ -153,6 +218,10 @@ int main() {
 #endif
 
 	TestSplitStr();
+#ifndef TEST_IN_SUBTHREAD
 	TestCronTimerInMainThread();
+#else
+    TestCronTimerInSubThread();
+#endif
 	return 0;
 }
diff --git a/include/cron_timer.h b/include/cron_timer.h
index c28548b..5bc5592 100644
--- a/include/cron_timer.h
+++ b/include/cron_timer.h
@@ -517,6 +517,14 @@ class TimerMgr {
 		return count;
 	}
 
+	void MarkMultiThreadsReady(bool ready = false) {
+        multi_threads_ready_ = ready;
+	}
+
+	bool MultiThreadsReady()
+	{
+		return multi_threads_ready_;
+	}
 private:
 	void insert(const TimerPtr& p) {
 		assert(!p->GetIsInList());
@@ -559,6 +567,7 @@ class TimerMgr {
 private:
 	std::map<std::chrono::system_clock::time_point, std::list<TimerPtr>> timers_;
 	bool stopped_ = false;
+	bool multi_threads_ready_ = false;
 };
 
 void BaseTimer::Cancel() {