我有一个脚本,我试图在凌晨 1 点使用 Rufus-Scheduler 创建每日时间表(基于日出和日落)。当我运行代码时,它似乎只运行第一个调度程序事件,之后不会运行任何事件。我的理解是 Rufus-Scheduler 应该为每个计划生成一个新线程,但它看起来像是阻塞的。我需要在新线程上生成时间表吗?我是否需要为要创建的每个计划创建一个新的计划程序实例?我在代码底部添加了一个测试调度程序,但它没有被创建。
这是与 rufus-scheduler 相关的代码部分
def get_todays_show()
this_year = Time.now.year
check_sunset
#the time format that comes back isn't reconginzed by rufus scheduler so recreate it with chronic
sunrise = Chronic.parse("#{@local_sunrise.to_s[0,10]} #{@local_sunrise.to_s[11,8]}" )
sunset = Chronic.parse("#{@local_sunset.to_s[0,10]} #{@local_sunset.to_s[11,8]}" )
schedule_array = create_array_from_csv
schedule_array.each do |sub_array|
earlier = Chronic.parse("#{sub_array[0]} #{this_year} 12:00:01 am")
later = Chronic.parse("#{sub_array[1]} #{this_year} 11:59:59")
range = earlier..later
if range.cover?(Time.now)
@scheduler.at sunset do
madrix_call(sub_array[2].strip)
end
@scheduler.at sunrise do
madrix_call(@off_slot)
end
end
end
end
#set up the scheduler
@scheduler = Rufus::Scheduler.start_new(:frequency => 30.0)
#run it once to handle today
get_todays_show
#the schedule to handle the future
@scheduler.cron '1 1 * * *' do
get_todays_show
p @scheduler.jobs
end
@scheduler.cron '* * * * *' do
p "test schedule - #{Time.now}"
end
@scheduler.join