add mutex

Author: wtlyu

Mirrors-AutoSync.py

@@ -13,6 +13,7 @@
 # ===========================================
 
 from apscheduler.schedulers.background import BackgroundScheduler,BlockingScheduler
+import threading
 import json
 import datetime, time
 import os
@@ -45,12 +46,15 @@ def __init__(self, name, schedule, exec, argument):
 	def runner(self):
 		global method_lock
 		global scheduler
+		global mutex
 
 		while method_lock > 1:
 			print("	[{}] waiting.".format(self.name))
 			time.sleep(10)
 
-		method_lock += 1
+		if mutex.acquire():  
+			method_lock += 1
+			mutex.release()  
 
 		try:
 
@@ -77,7 +81,10 @@ def runner(self):
 						self.name,
 						next_run_time = datetime.datetime.now() + datetime.timedelta(seconds = 10*60),)
 		finally:
-			method_lock -= 1
+
+			if mutex.acquire():  
+				method_lock -= 1
+				mutex.release()  
 
 	def setup(self, scheduler):
 		scheduler.add_job(
@@ -130,6 +137,7 @@ def setup(self, scheduler):
 status_file_dir = content['status_file_dir']
 
 method_lock = 0
+mutex = threading.Lock()
 
 for i in content['schedules']:
 	t = task(i['name'], i['schedule'], i['exec'], i['argument'])