🗒️ Job Queue Library

The job queue library provides a useful way to schedule functions to run sequentially.

This can be used when devices need data extracting, configuration changes, and diagnostics.
Other tasks can post to the job queue and the function callbacks will be run strictly in order.

Example:

jq = jobq.new()

-- …in some function
jq:add(MyFunc1, {1,2,3,'ABC'})
jq:add(MyFunc2, {'ABC',t})

-- …in the context of some thread:
while tools.run() and (#jq > 0)
do
  local ji = {jq:poprun()}
  if not ji[1] then break end
  -- do something with ji[2]..ji[n]
end

Hint

You can combine this with 🗒️ Semaphore Object Intro

Example:

mjq = jobq.new()

function MyJob1(a1,a2)
-- so something with a1 & a2
end

function MyJob2()
-- do work
end

...
mjq:add(MyJob1, {42, 'Interesting'})
mjq:add(MyJob2)

...
mjq:run() -- runs all jobs

Example for #Firmware/v320 :

mjq = jobq.new(semaphore.new())

function MyJobThread(the_thread, the_name)
 while the_thread:run()
 do
  if mjq.sem:wait(500)
  then
    mjq:runall()
  end
 end
end

…
mjq:add(MyJob1, {42, 'Interesting'}) -- will implicitly call mjq.sem:release()