action_queues

provides an API for queuing things for batch processing w/ various ways to specify the batch "size".

api

• action_queues.api.create_serverstep_queue(params) returns a queue, to which jobs can be added which will execute on some future server step. params can be one of
• {us_per_step = n} execute queued entries until n us (microseconds) have elapsed.
• {every_n_steps = n, num_per_step = m} execute at most m queued entries every n server steps.
• {every_n_seconds = n, num_per_step = m} execute at most m queued entries after at least n seconds have elapsed.
• {num_per_step = m} execute at most m queued entries on each server step.

to add entires to the queue, do

queue:push_back(function(params, dtime, n)
    ...
end)

if the function returns "true", queue processing will be stopped until the next cycle.