worker.h

 
#ifndef KERNEL_WORKER_H
#define KERNEL_WORKER_H
 
#include <kernel/error.h>
#include <kernel/waitqueue.h>
 
struct worker {
    struct thread *thread;   
    struct waitqueue queue;  
    bool done;               
    thread_entry_t function; 
    void *data;              
};
 
#define INIT_WORKER(_worker)                        \
    _worker = ((struct worker){                     \
        .queue = __WAITQUEUE_INIT((_worker).queue), \
        .done = true,                               \
        .thread = NULL,                             \
    })
 
#define DECLARE_WORKER(_worker) struct worker INIT_WORKER(_worker)
 
error_t worker_init(struct worker *);
 
void worker_start(struct worker *, thread_entry_t, void *);
 
void worker_wait(struct worker *);
 
void worker_release(struct worker *);
 
static inline bool worker_running(const struct worker *worker)
{
    return !worker->done;
}
 
#endif /* KERNEL_WORKER_H */