python
from apscheduler.schedulers.gevent import GeventScheduler
scheduler = GeventScheduler()
scheduler.add_job(my_task, 'interval', seconds=10)
scheduler.start()
python
from apscheduler.schedulers.blocking import BlockingScheduler
scheduler = BlockingScheduler({
'misfire_grace_time': 5,
'coalesce': True,
'max_instances': 3
})
python
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from apscheduler.schedulers.blocking import BlockingScheduler
from sqlalchemy import create_engine
engine = create_engine('sqlite:///scheduler.db')
jobstore = SQLAlchemyJobStore(engine=engine)
scheduler = BlockingScheduler(jobstores={'default': jobstore})
python
from concurrent.futures import ThreadPoolExecutor
from apscheduler.schedulers.blocking import BlockingScheduler
executor = ThreadPoolExecutor(max_workers=20)
scheduler = BlockingScheduler(executor=executor)