{

bool err = false;

do

{

if(_thread_count <= 0 || _thread_count > MAX_THREADS || _queue_size <= 0 || _queue_size > MAX_QUEUE)

{

_thread_count = 4;

_queue_size = 1024;

}

thread_count = 0;

queue_size = _queue_size;

head = tail = count = 0;

shutdown = started = 0;

threads.resize(_thread_count);

queue.resize(_queue_size);

/* Start worker threads */

for(int i = 0; i < _thread_count; ++i)

{

if(pthread_create(&threads[i], NULL, threadpool_thread, (void*)(0)) != 0)

{

//threadpool_destroy(pool, 0);

return -1;

}

++thread_count;

++started;

}

} while(false);

if (err)

{

//threadpool_free(pool);

return -1;

}

return 0;

{

int next, err = 0;

if(pthread_mutex_lock(&lock) != 0)

return THREADPOOL_LOCK_FAILURE;

do

{

next = (tail + 1) % queue_size;

// 队列满

if(count == queue_size)

{

err = THREADPOOL_QUEUE_FULL;

break;

}

// 已关闭

if(shutdown)

{

err = THREADPOOL_SHUTDOWN;

break;

}

queue[tail].fun = fun;

queue[tail].args = args;

tail = next;

++count;

/* pthread_cond_broadcast */

if(pthread_cond_signal(&notify) != 0)

{

err = THREADPOOL_LOCK_FAILURE;

break;

}

} while(false);

if(pthread_mutex_unlock(&lock) != 0)

err = THREADPOOL_LOCK_FAILURE;

return err;

{

printf("Thread pool destroy !\n");

int i, err = 0;

if(pthread_mutex_lock(&lock) != 0)

{

return THREADPOOL_LOCK_FAILURE;

}

do

{

if(shutdown) {

err = THREADPOOL_SHUTDOWN;

break;

}

shutdown = shutdown_option;

if((pthread_cond_broadcast(&notify) != 0) ||

(pthread_mutex_unlock(&lock) != 0)) {

err = THREADPOOL_LOCK_FAILURE;

break;

}

for(i = 0; i < thread_count; ++i)

{

if(pthread_join(threads[i], NULL) != 0)

{

err = THREADPOOL_THREAD_FAILURE;

}

}

} while(false);

if(!err)

{

threadpool_free();

}

return err;

{

if(started > 0)

return -1;

pthread_mutex_lock(&lock);

pthread_mutex_destroy(&lock);

pthread_cond_destroy(&notify);

return 0;