diff options
| author | @syxhe <https://t.me/syxhe> | 2025-05-14 13:20:21 -0500 |
|---|---|---|
| committer | @syxhe <https://t.me/syxhe> | 2025-05-14 13:20:21 -0500 |
| commit | 5a5ff094101d63935f7fc65c124b3e56d553522d (patch) | |
| tree | 3bf3254cb491dc6aef6dd3b3bafaef9709ade9ba /src/threadpool.h | |
| parent | 928238bdcbc78c4196eb4a3508808c79e31f7c84 (diff) | |
Start reimplementing some of the earlier concurrent queue code
Diffstat (limited to 'src/threadpool.h')
| -rw-r--r-- | src/threadpool.h | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/threadpool.h b/src/threadpool.h index bd1b787..db6fa2e 100644 --- a/src/threadpool.h +++ b/src/threadpool.h | |||
| @@ -12,11 +12,9 @@ task * task_init(task_callback cb, void *arg); | |||
| 12 | void task_free(task *ts); | 12 | void task_free(task *ts); |
| 13 | int task_fire(task *ts); | 13 | int task_fire(task *ts); |
| 14 | 14 | ||
| 15 | cqueue * cqueue_init(int mtx_type); | 15 | cqueue * cqueue_init(); |
| 16 | void cqueue_cancel(cqueue * const cq); | ||
| 17 | void cqueue_free(void *cq); | ||
| 16 | 18 | ||
| 17 | void cqueue_cancel(cqueue *cq); | ||
| 18 | void cqueue_free(cqueue *cq); | ||
| 19 | int cqueue_addtask(cqueue * const cq, task * const tsk); | ||
| 20 | task * cqueue_waitpop(cqueue * const cq); | ||
| 21 | 19 | ||
| 22 | #endif \ No newline at end of file | 20 | #endif \ No newline at end of file |
