_configure
self._logger = getLogger('apscheduler.scheduler')
self.timezone = astimezone(config.pop('timezone', None)) or get_localzone()
_job_defaults<br>
'misfire_grace_time': 过期时间, 超过多少秒,就废弃,<br> 'coalesce': 如果job过期,只取几个,其他都废弃,<br> 'max_instances': 同一个job几个线程在同时运行<br>
self.add_executor(executor, alias)
add_jobstore
jobstore.start(self, alias)
self.wakeup()
self._event.set()
add_job<br>
job = Job(self, **job_kwargs)
self.state
STATE_STOPPED
self._pending_jobs.append((job, jobstore, replace_existing))
else
self._real_add_job(job, jobstore, replace_existing)<br>
update job defaults / next_run_time<br>
job_store.add_job(job)/ store.update_job(job)<br>
self.wakeup()
start
self._event = Event()
BaseScheduler.start(self, *args, **kwargs)
executor.start(self, alias)
store.start(self, alias)
self._real_add_job(job, jobstore_alias, replace_existing) from self._pending_jobs<br>
while True : self._process_jobs()<br>
遍历self._jobstores
jobstore.get_due_jobs(now)<br>
for job in due_jobs:
run_times = job._get_run_times(now)
executor.submit_job(job, run_times)
job_next_run = job.trigger.get_next_fire_time(run_times[-1], now)
if job_next_run:<br> job._modify(next_run_time=job_next_run)<br> jobstore.update_job(job)<br> else:<br> self.remove_job(job.id, jobstore_alias)
jobstore_next_run_time = jobstore.get_next_run_time()
jobstore_next_run_time 可能会提前 根据业务逻辑
