Mercurial > hg > nginx
changeset 6039:fc36690e7f44
Thread pools: replaced completed tasks queue mutex with spinlock.
author | Valentin Bartenev <vbart@nginx.com> |
---|---|
date | Mon, 23 Mar 2015 17:51:21 +0300 |
parents | 94ce52db3367 |
children | adaedab1e662 |
files | src/core/ngx_thread_pool.c |
diffstat | 1 files changed, 5 insertions(+), 16 deletions(-) [+] |
line wrap: on
line diff
--- a/src/core/ngx_thread_pool.c Mon Mar 23 13:52:47 2015 +0300 +++ b/src/core/ngx_thread_pool.c Mon Mar 23 17:51:21 2015 +0300 @@ -99,6 +99,7 @@ static ngx_str_t ngx_thread_pool_default = ngx_string("default"); static ngx_uint_t ngx_thread_pool_task_id; +static ngx_atomic_t ngx_thread_pool_done_lock; static ngx_thread_pool_queue_t ngx_thread_pool_done; @@ -329,20 +330,12 @@ task->next = NULL; - if (ngx_thread_mutex_lock(&ngx_thread_pool_done.mtx, tp->log) - != NGX_OK) - { - return NULL; - } + ngx_spinlock(&ngx_thread_pool_done_lock, 1, 2048); *ngx_thread_pool_done.last = task; ngx_thread_pool_done.last = &task->next; - if (ngx_thread_mutex_unlock(&ngx_thread_pool_done.mtx, tp->log) - != NGX_OK) - { - return NULL; - } + ngx_unlock(&ngx_thread_pool_done_lock); (void) ngx_notify(ngx_thread_pool_handler); } @@ -357,17 +350,13 @@ ngx_log_debug0(NGX_LOG_DEBUG_CORE, ev->log, 0, "thread pool handler"); - if (ngx_thread_mutex_lock(&ngx_thread_pool_done.mtx, ev->log) != NGX_OK) { - return; - } + ngx_spinlock(&ngx_thread_pool_done_lock, 1, 2048); task = ngx_thread_pool_done.first; ngx_thread_pool_done.first = NULL; ngx_thread_pool_done.last = &ngx_thread_pool_done.first; - if (ngx_thread_mutex_unlock(&ngx_thread_pool_done.mtx, ev->log) != NGX_OK) { - return; - } + ngx_unlock(&ngx_thread_pool_done_lock); while (task) { ngx_log_debug1(NGX_LOG_DEBUG_CORE, ev->log, 0,