|
@@ -6,13 +6,14 @@ from django_apscheduler.models import DjangoJob
|
|
|
import datetime
|
|
import datetime
|
|
|
import rpyc
|
|
import rpyc
|
|
|
from apscheduler.executors.pool import ProcessPoolExecutor
|
|
from apscheduler.executors.pool import ProcessPoolExecutor
|
|
|
|
|
+from apscheduler.executors.pool import ThreadPoolExecutor
|
|
|
|
|
|
|
|
|
|
|
|
|
class ApschedulerObject:
|
|
class ApschedulerObject:
|
|
|
def __init__(self):
|
|
def __init__(self):
|
|
|
self.scheduler = BackgroundScheduler(
|
|
self.scheduler = BackgroundScheduler(
|
|
|
executors={
|
|
executors={
|
|
|
- 'default': ProcessPoolExecutor(1) # 最多3个进程同时运行
|
|
|
|
|
|
|
+ 'default': ThreadPoolExecutor(1) # 最多3个进程同时运行
|
|
|
})
|
|
})
|
|
|
self.scheduler.add_jobstore(DjangoJobStore(), 'default')
|
|
self.scheduler.add_jobstore(DjangoJobStore(), 'default')
|
|
|
self.scheduler.start()
|
|
self.scheduler.start()
|
