thread_pool.h

Go to the documentation of this file.

#ifndef KEEL_THREAD_POOL_H
#define KEEL_THREAD_POOL_H
 
#include <keel/allocator.h>
 
typedef struct KlEventCtx KlEventCtx;
 
typedef void (*KlWorkFn)(void *user_data);
typedef void (*KlWorkDoneFn)(void *user_data);
typedef void (*KlWorkCancelFn)(void *user_data);
 
typedef struct KlWorkItem {
    KlWorkFn work_fn;           
    KlWorkDoneFn done_fn;       
    KlWorkCancelFn cancel_fn;   
    void *user_data;            
} KlWorkItem;
 
typedef struct KlThreadPoolConfig {
    int num_workers;          
    int queue_capacity;       
    KlAllocator *alloc;       
} KlThreadPoolConfig;
 
typedef struct KlThreadPool KlThreadPool;
 
KlThreadPool *kl_thread_pool_create(KlEventCtx *ctx, const KlThreadPoolConfig *cfg);
 
int kl_thread_pool_submit(KlThreadPool *pool, const KlWorkItem *item);
 
void kl_thread_pool_free(KlThreadPool *pool);
 
#endif