🗒️Using Job Lists and Job Entry Objects

myq = job.new(semaphore.new())

-- The job dispatcher, running in its own thread
-- (Job callbacks are run in this context)
function MyJobThread(the_thread, the_name)
 while the_thread:run()
 do
  if mjq.sem:wait(500)
  then
    mjq:runall()
  end
 end
end

-- Chreate the thread
mqt = thread.new(JobThread, 'JobThread')

-- Glue the job list mechanism into the x.onsecond...
job.run()

-- A sample job callback
function MyJobE1(jobe, utc, u)
  local id   = jobe:id()
  local args = jobe:args()
  -- do some work (called in the context of JobThread)
end

-- Create the job entry object (not yet active)
mj = job.new('test', '00:01:00' myq, MyJobE1)
-- And add to the job list
job.add(mj)

-- Another sample job callback
function MyJobE2(jobe, utc, u)
  -- do something (again in the context of JobThread)
end

-- Abbreviated - create and add in one line.
job.add(job.new('test2', '01:00:00', myq, MyJobE2))

-- Adjust an entry's schedule...
job.get('test2'):set('00:30:00')
-- Safer: mj = job.get('test2'); if mj then mj:set('00:30:00') end