Project
Loading...
Searching...
No Matches
Static Public Member Functions | List of all members
o2::framework::AsyncQueueHelpers Struct Reference

#include <AsyncQueue.h>

Static Public Member Functions

static AsyncTaskId create (AsyncQueue &queue, AsyncTaskSpec spec)
 
static void post (AsyncQueue &queue, AsyncTask const &task)
 
static void run (AsyncQueue &queue, TimesliceId oldestPossibleTimeslice)
 
static void flushPending (AsyncQueue &queue)
 
static void reset (AsyncQueue &queue)
 Reset the queue to its initial state.
 

Detailed Description

Definition at line 105 of file AsyncQueue.h.

Member Function Documentation

◆ create()

auto o2::framework::AsyncQueueHelpers::create ( AsyncQueue &  queue,
AsyncTaskSpec  spec 
)
static

Definition at line 27 of file AsyncQueue.cxx.

◆ flushPending()

auto o2::framework::AsyncQueueHelpers::flushPending ( AsyncQueue &  queue)
static

Definition at line 45 of file AsyncQueue.cxx.

◆ post()

auto o2::framework::AsyncQueueHelpers::post ( AsyncQueue &  queue,
AsyncTask const &  task 
)
static

Definition at line 35 of file AsyncQueue.cxx.

◆ reset()

auto o2::framework::AsyncQueueHelpers::reset ( AsyncQueue &  queue)
static

Reset the queue to its initial state.

Definition at line 159 of file AsyncQueue.cxx.

◆ run()

auto o2::framework::AsyncQueueHelpers::run ( AsyncQueue &  queue,
TimesliceId  oldestPossibleTimeslice 
)
static

Run all the tasks which are older than the oldestPossible timeslice executing them by:

  1. sorting the tasks by timeslice
  2. then priority
  3. only execute the highest (timeslice, debounce) value

Definition at line 63 of file AsyncQueue.cxx.

The documentation for this struct was generated from the following files: