comparison: src/server/util/thrpool.c
src/server/util/thrpool.c
- branch
- webdav
- changeset 357
- f45e962edf45
- parent 115
- 51d9a15eac98
- child 358
- f3b490a2150c
equal
deleted
inserted
replaced
| 356:eebc3d32c7c1 | 357:f45e962edf45 |
|---|---|
| 45 pool->max_threads = max; | 45 pool->max_threads = max; |
| 46 pool->num_threads = 0; | 46 pool->num_threads = 0; |
| 47 | 47 |
| 48 pthread_mutex_init(&pool->queue_lock, NULL); | 48 pthread_mutex_init(&pool->queue_lock, NULL); |
| 49 pthread_mutex_init(&pool->avlbl_lock, NULL); | 49 pthread_mutex_init(&pool->avlbl_lock, NULL); |
| 50 pthread_cond_init(&pool->available, NULL); | 50 pthread_cond_init(&pool->available, NULL); |
| 51 | 51 |
| 52 return pool; | |
| 53 } | |
| 54 | |
| 55 int threadpool_start(threadpool_t *pool) { | |
| 52 /* create pool threads */ | 56 /* create pool threads */ |
| 53 for(int i=0;i<min;i++) { | 57 for(int i=0;i<pool->min_threads;i++) { |
| 54 pthread_t t; | 58 pthread_t t; |
| 55 if (pthread_create(&t, NULL, threadpool_func, pool) != 0) { | 59 if (pthread_create(&t, NULL, threadpool_func, pool) != 0) { |
| 56 perror("Error: threadpool_new: pthread_create"); | 60 perror("Error: threadpool_start: pthread_create"); |
| 57 return NULL; | 61 return 1; |
| 58 } | 62 } |
| 59 } | 63 } |
| 60 | 64 return 0; |
| 61 return pool; | |
| 62 } | 65 } |
| 63 | 66 |
| 64 void* threadpool_func(void *data) { | 67 void* threadpool_func(void *data) { |
| 65 threadpool_t *pool = (threadpool_t*)data; | 68 threadpool_t *pool = (threadpool_t*)data; |
| 66 | 69 |
