запустить работу после того, как предыдущая работа полностью выполнена в apscheduler? - PullRequest
0 голосов
/ 07 июня 2018

У меня проблема с синхронизацией.

from apscheduler.schedulers.background import BackgroundScheduler, BlockingScheduler
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
import time

budget = 100000

def plus() :
    global budget
    time.sleep(3)
    budget += 20000
    print('plus called, budget : ', budget)

def minus() :
    global budget
    budget -= 10000
    print('minus called, budget : ', budget)

executors = {'default' : ProcessPoolExecutor(1)}
sched = BackgroundScheduler(executors)

sched.add_job(plus, 'interval', seconds = 5, misfire_grace_time=20, max_instances=1)
sched.add_job(minus, 'interval', seconds = 6, misfire_grace_time=20,  max_instances=1)

sched.start()

Как сделать так, чтобы «минус» начинался после «плюс», чтобы быть полностью готовым?

...