thrpool.h

Go to the documentation of this file.

// SPDX-License-Identifier: MIT
#ifndef __THRPOOL_H__
#define __THRPOOL_H__
 
#include <limits.h>
#include <pthread.h>
 
typedef struct crinitThreadPool_t {
    size_t poolSize;                    
    size_t poolSizeIncrement;           
    size_t threadAvail;                 
    pthread_mutex_t lock;               
    pthread_cond_t threadAvailChanged;  
    pthread_t dryPoolWdRef;  
 
    void *(*threadFunc)(void *args);  
    void *thrArgs;                    
    size_t thrArgsSize;               
} crinitThreadPool_t;
 
#define CRINIT_THREADPOOL_DEFAULT_INITIAL_SIZE 8
#define CRINIT_THREADPOOL_THREAD_STACK_SIZE (PTHREAD_STACK_MIN + 112 * 1024)
 
int crinitThreadPoolInit(crinitThreadPool_t *ctx, size_t initialSize, void *(*threadFunc)(void *), const void *thrArgs,
                         size_t thrArgsSize);
 
int crinitThreadPoolThreadBusyCallback(crinitThreadPool_t *ctx);
int crinitThreadPoolThreadAvailCallback(crinitThreadPool_t *ctx);
 
#endif /* __THRPOOL_H__ */