3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Nginx, Inc.
8 #ifndef _NGX_THREAD_H_INCLUDED_
9 #define _NGX_THREAD_H_INCLUDED_
12 #include <ngx_config.h>
17 #define NGX_MAX_THREADS 128
20 #include <ngx_freebsd_rfork_thread.h>
23 #else /* use pthreads */
27 typedef pthread_t ngx_tid_t
;
29 #define ngx_thread_self() pthread_self()
30 #define ngx_log_tid (int) ngx_thread_self()
32 #if (NGX_FREEBSD) && !(NGX_LINUXTHREADS)
33 #define NGX_TID_T_FMT "%p"
35 #define NGX_TID_T_FMT "%d"
39 typedef pthread_key_t ngx_tls_key_t
;
41 #define ngx_thread_key_create(key) pthread_key_create(key, NULL)
42 #define ngx_thread_key_create_n "pthread_key_create()"
43 #define ngx_thread_set_tls pthread_setspecific
44 #define ngx_thread_set_tls_n "pthread_setspecific()"
45 #define ngx_thread_get_tls pthread_getspecific
48 #define NGX_MUTEX_LIGHT 0
51 pthread_mutex_t mutex
;
60 #define ngx_thread_sigmask pthread_sigmask
61 #define ngx_thread_sigmask_n "pthread_sigmask()"
63 #define ngx_thread_join(t, p) pthread_join(t, p)
65 #define ngx_setthrtitle(n)
69 ngx_int_t
ngx_mutex_trylock(ngx_mutex_t
*m
);
70 void ngx_mutex_lock(ngx_mutex_t
*m
);
71 void ngx_mutex_unlock(ngx_mutex_t
*m
);
76 #define ngx_thread_volatile volatile
85 #define NGX_THREAD_FREE 1
86 #define NGX_THREAD_BUSY 2
87 #define NGX_THREAD_EXIT 3
88 #define NGX_THREAD_DONE 4
90 extern ngx_int_t ngx_threads_n
;
91 extern volatile ngx_thread_t ngx_threads
[NGX_MAX_THREADS
];
94 typedef void * ngx_thread_value_t
;
96 ngx_int_t
ngx_init_threads(int n
, size_t size
, ngx_cycle_t
*cycle
);
97 ngx_err_t
ngx_create_thread(ngx_tid_t
*tid
,
98 ngx_thread_value_t (*func
)(void *arg
), void *arg
, ngx_log_t
*log
);
100 ngx_mutex_t
*ngx_mutex_init(ngx_log_t
*log
, ngx_uint_t flags
);
101 void ngx_mutex_destroy(ngx_mutex_t
*m
);
104 ngx_cond_t
*ngx_cond_init(ngx_log_t
*log
);
105 void ngx_cond_destroy(ngx_cond_t
*cv
);
106 ngx_int_t
ngx_cond_wait(ngx_cond_t
*cv
, ngx_mutex_t
*m
);
107 ngx_int_t
ngx_cond_signal(ngx_cond_t
*cv
);
110 #else /* !NGX_THREADS */
112 #define ngx_thread_volatile
114 #define ngx_log_tid 0
115 #define NGX_TID_T_FMT "%d"
117 #define ngx_mutex_trylock(m) NGX_OK
118 #define ngx_mutex_lock(m)
119 #define ngx_mutex_unlock(m)
121 #define ngx_cond_signal(cv)
123 #define ngx_thread_main() 1
128 #endif /* _NGX_THREAD_H_INCLUDED_ */