我在使用apscheduler来做定时任务,每分钟从接口取数据存入redis,然而这个接口有时候会因为各种原因导致阻塞,使得下一分钟的任务无法执行,请问有什么方法可以给函数getRealtimeData
加个timeout,一旦超时则终结此线程。
if __name__ == '__main__':
scheduler = TornadoScheduler()
scheduler.add_job(getRealtimeData, 'cron', second=40)
scheduler.start()
print 'Press Ctrl+{} to exit.'.format('Break' if os.name == 'nt' else 'C')
IOLoop.instance().start()
拥有18年软件开发和IT教学经验。曾任多家上市公司技术总监、架构师、项目经理、高级软件工程师等职务。 网络人气名人讲师,...