diff options
Diffstat (limited to 'src/thrd/pool.h')
| -rwxr-xr-x | src/thrd/pool.h | 78 |
1 files changed, 38 insertions, 40 deletions
diff --git a/src/thrd/pool.h b/src/thrd/pool.h index 71ecaa9..cbd1e83 100755 --- a/src/thrd/pool.h +++ b/src/thrd/pool.h @@ -8,60 +8,58 @@ using namespace std; class pool { private: - static int i_thrd_used; + static int i_thrd_used; - typedef struct tpool_work - { - void (*routine)(void*); /// - void *p_void; - struct tpool_work *next; - } - tpool_work_t; + typedef struct tpool_work { + void (*routine)(void*); /// + void *p_void; + struct tpool_work *next; + } + tpool_work_t; - typedef struct tpool - { - // pool characteristics: - int num_threads; - int max_queue_size; + typedef struct tpool + { + // pool characteristics: + int num_threads; + int max_queue_size; - // pool state - pthread_t *threads; - int cur_queue_size; + // pool state + pthread_t *threads; + int cur_queue_size; - tpool_work_t *queue_head; - tpool_work_t *queue_tail; + tpool_work_t *queue_head; + tpool_work_t *queue_tail; - pthread_mutex_t queue_lock; - pthread_cond_t queue_not_empty; - pthread_cond_t queue_not_full; - pthread_cond_t queue_empty; - } - *tpool_t; + pthread_mutex_t queue_lock; + pthread_cond_t queue_not_empty; + pthread_cond_t queue_not_full; + pthread_cond_t queue_empty; + } + *tpool_t; - int i_thrd_pool_size; - int i_thrd_pool_queue; + int i_thrd_pool_size; + int i_thrd_pool_queue; - tpool_t thread_pool; + tpool_t thread_pool; - void tpool_init( tpool_t *tpoolp, int num_worker_threads, int max_queue_size); - int tpool_add_work( tpool_t tpool, void(*routine)(void*), void* p_void ); - static void* tpool_thread( void *p_void); - static void run_func( void *p_void ); + void tpool_init( tpool_t *tpoolp, int num_worker_threads, int max_queue_size); + int tpool_add_work( tpool_t tpool, void(*routine)(void*), void* p_void ); + static void* tpool_thread( void *p_void); + static void run_func( void *p_void ); public: - pool(); + pool(); - // inline (speed)! - void run( void *p_void ) - { - tpool_add_work( thread_pool, run_func, p_void ); - } + // inline (speed)! + void run( void *p_void ) + { + tpool_add_work( thread_pool, run_func, p_void ); + } #ifdef NCURSES - void print_pool_size(); - static void print_threads(int i_thrd_used); + void print_pool_size(); + static void print_threads(int i_thrd_used); #endif - }; #endif |
