From ca28c0e618890330d429c0dc12429255b20f0c90 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sat, 6 Apr 2013 13:14:44 +0200 Subject: tagging ychat-0.5.0 --- pool.h | 98 +++++++++++++++++++++++++++++++++--------------------------------- 1 file changed, 49 insertions(+), 49 deletions(-) (limited to 'pool.h') diff --git a/pool.h b/pool.h index 7230760..358b79f 100755 --- a/pool.h +++ b/pool.h @@ -7,71 +7,71 @@ using namespace std; -class pool +class pool { private: - typedef struct tpool_work - { - void (*routine)(void*); /// - void *arg; - struct tpool_work *next; - } - tpool_work_t; + typedef struct tpool_work + { + void (*routine)(void*); /// + void *arg; + struct tpool_work *next; + } + tpool_work_t; - typedef struct tpool - { - // pool characteristics: - int num_threads; - int max_queue_size; - int do_not_block_when_full; + typedef struct tpool + { + // pool characteristics: + int num_threads; + int max_queue_size; + int do_not_block_when_full; - // 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; + pthread_mutex_t queue_lock; + pthread_cond_t queue_not_empty; + pthread_cond_t queue_not_full; + pthread_cond_t queue_empty; - int queue_closed; - int shutdown; - } - *tpool_t; + int queue_closed; + int shutdown; + } + *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; - virtual void - tpool_init( tpool_t *tpoolp, int num_worker_threads, int max_queue_size, int do_not_block_when_full ); + virtual void + tpool_init( tpool_t *tpoolp, int num_worker_threads, int max_queue_size, int do_not_block_when_full ); - virtual int - tpool_add_work( tpool_t tpool, void(*routine)(void*), void* arg ); + virtual int + tpool_add_work( tpool_t tpool, void(*routine)(void*), void* arg ); - // virtual void - // tpool_destroy( tpool_t tpoolp, int finish ); +// virtual void +// tpool_destroy( tpool_t tpoolp, int finish ); - static void* - tpool_thread( void* arg); + static void* + tpool_thread( void* arg); - static void - run_func( void *v_pointer ); + static void + run_func( void *v_pointer ); - // public methods: + // public methods: public: - explicit pool( ); - ~pool(); - - // inline (speed)! - void run( void *arg ) - { - tpool_add_work( thread_pool, run_func, arg ); - } + explicit pool( ); + ~pool(); + + // inline (speed)! + void run( void *arg ) + { + tpool_add_work( thread_pool, run_func, arg ); + } }; #endif -- cgit v1.2.3