task.h

Go to the documentation of this file.

#ifndef LARLIB_TASK_H
#define LARLIB_TASK_H

#include <larlib/base.h>

#define TASK_INFINITE_TIMEOUT (0xFFFFFFFFLU)

typedef struct taskThread_t taskThread_t;

typedef void (*taskThreadFunction_t)(void *param);

typedef struct taskQueue_t taskQueue_t;

typedef struct taskSemaphore_t taskSemaphore_t;

typedef struct taskEvent_t taskEvent_t;

taskThread_t *taskThreadCreate(taskThreadFunction_t fn, void *param, uint32_t stackSize);

void taskSleep(uint32_t timeout);

taskThread_t *taskThreadCurrent(void);

taskQueue_t *taskQueueCreate(int maxItems);

void taskQueueDestroy(taskQueue_t *q);

int taskQueuePost(taskQueue_t *q, void *item);

int taskQueuePop(taskQueue_t *q, void **item, uint32_t timeout);

taskSemaphore_t *taskSemaphoreCreate(int limit);

void taskSemaphoreDestroy(taskSemaphore_t *s);

int taskSemaphoreAcquire(taskSemaphore_t *s, uint32_t timeout);

int taskSemaphoreRelease(taskSemaphore_t *s);

taskEvent_t *taskEventCreate(void);

taskEvent_t *taskEventCreateSystem(uint32_t bitmask);

void taskEventDestroy(taskEvent_t *e);

int taskEventSignal(taskEvent_t *e);

int taskEventCheck(taskEvent_t *e);

int taskEventWait(taskEvent_t *e, uint32_t timeout);

int taskEventWaitAny(taskEvent_t *events[], int nevents, uint32_t timeout);

int taskEventClear(taskEvent_t *e);

/* @} */

#endif