|
@@ -5,7 +5,7 @@ import time
|
|
|
from model.DingTalkUtils import DingTalkUtils
|
|
|
import logging
|
|
|
from logging import handlers
|
|
|
-import threading
|
|
|
+import multiprocessing
|
|
|
|
|
|
du = DateUtils()
|
|
|
|
|
@@ -31,15 +31,15 @@ if __name__ == '__main__':
|
|
|
logging.info('广告素材任务,开始')
|
|
|
st = time.time()
|
|
|
|
|
|
- hourly_thread = threading.Thread(target=hourly_run)
|
|
|
- hourly_thread.daemon = True
|
|
|
- hourly_thread.start()
|
|
|
+ hourly_process = multiprocessing.Process(target=hourly_run)
|
|
|
+ hourly_process.daemon = True
|
|
|
+ hourly_process.start()
|
|
|
|
|
|
while 1:
|
|
|
if time.time() - st > 3000:
|
|
|
- logging.info('线程运行超过50分钟,强制停止')
|
|
|
+ logging.info('进程运行超过50分钟,强制停止')
|
|
|
break
|
|
|
- if not hourly_thread.is_alive():
|
|
|
+ if not hourly_process.is_alive():
|
|
|
break
|
|
|
|
|
|
if int(time.time() - st) > 1500:
|