summaryrefslogtreecommitdiff
path: root/src/thrd/pool.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/thrd/pool.h')
-rwxr-xr-xsrc/thrd/pool.h78
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