File syn_workqueue.h

File List > sched > syn_workqueue.h

Go to the documentation of this file

#ifndef SYN_WORKQUEUE_H
#define SYN_WORKQUEUE_H

#include "../util/syn_spsc_queue.h"

#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>

#ifdef __cplusplus
extern "C" {
#endif

typedef void (*SYN_WorkFunc)(void *ctx);

typedef struct {
    SYN_WorkFunc func; 
    void *ctx;         
} SYN_WorkItem;

typedef struct {
    SYN_SPSC_Queue queue; 
    uint32_t overflow;    
} SYN_WorkQueue;

void syn_workqueue_init(SYN_WorkQueue *wq, SYN_WorkItem *buf, size_t capacity);

bool syn_workqueue_post(SYN_WorkQueue *wq, SYN_WorkFunc func, void *ctx);

size_t syn_workqueue_process(SYN_WorkQueue *wq);

static inline bool syn_workqueue_empty(const SYN_WorkQueue *wq)
{
    return syn_spsc_queue_is_empty(&wq->queue);
}

static inline size_t syn_workqueue_pending(const SYN_WorkQueue *wq)
{
    return syn_spsc_queue_count(&wq->queue);
}

static inline uint32_t syn_workqueue_overflows(const SYN_WorkQueue *wq)
{
    return wq->overflow;
}

#ifdef __cplusplus
}
#endif

#endif /* SYN_WORKQUEUE_H */