Data Fields
struct workerthread_t **	threads

tor_cond_t	condition

work_tailq_t	work [WORKQUEUE_N_PRIORITIES]

unsigned	generation

workqueue_reply_t(*	update_fn )(void , void )

void(*	free_update_arg_fn )(void *)

void **	update_args

struct event *	reply_event

void(*	reply_cb )(threadpool_t *)

int	n_threads

tor_mutex_t	lock

replyqueue_t *	reply_queue

void (	new_thread_state_fn )(void *)

void(*	free_thread_state_fn )(void *)

void *	new_thread_state_arg

Detailed Description

A thread-pool manages starting threads and passing work to them.

Definition at line 53 of file workqueue.c.

Field Documentation

◆ condition

tor_cond_t condition

Condition variable that we wait on when we have no work, and which gets signaled when our queue becomes nonempty.

Definition at line 60 of file workqueue.c.

◆ free_thread_state_fn

void(* free_thread_state_fn) (void *)

Definition at line 89 of file workqueue.c.

◆ free_update_arg_fn

void(* free_update_arg_fn) (void *)

Function to free update arguments if they can't be run.

Definition at line 72 of file workqueue.c.

Referenced by threadpool_queue_update().

◆ generation

unsigned generation

The current 'update generation' of the threadpool. Any thread that is at an earlier generation needs to run the update function.

Definition at line 67 of file workqueue.c.

Referenced by worker_thread_main().

◆ lock

tor_mutex_t lock

Mutex to protect all the above fields.

Definition at line 82 of file workqueue.c.

Referenced by threadpool_queue_update(), and worker_thread_main().

◆ n_threads

int n_threads

Number of elements in threads.

Definition at line 80 of file workqueue.c.

Referenced by threadpool_get_n_threads(), and threadpool_queue_update().

◆ new_thread_state_arg

void* new_thread_state_arg

Definition at line 90 of file workqueue.c.

◆ new_thread_state_fn

void *(* new_thread_state_fn) (void *)

Functions used to allocate and free thread state.

Definition at line 88 of file workqueue.c.

◆ reply_cb

void(* reply_cb) (threadpool_t *)

Definition at line 77 of file workqueue.c.

◆ reply_event

struct event* reply_event

Event to notice when another thread has sent a reply.

Definition at line 76 of file workqueue.c.

Referenced by threadpool_register_reply_event().

◆ reply_queue

replyqueue_t* reply_queue

A reply queue to use when constructing new threads.

Definition at line 85 of file workqueue.c.

Referenced by reply_event_cb(), and threadpool_get_replyqueue().

◆ threads

struct workerthread_t** threads

An array of pointers to workerthread_t: one for each running worker thread.

Definition at line 56 of file workqueue.c.

◆ update_args

void** update_args

Array of n_threads update arguments.

Definition at line 74 of file workqueue.c.

Referenced by threadpool_queue_update(), and worker_thread_main().

◆ update_fn

workqueue_reply_t(* update_fn) (void *, void *)

Function that should be run for updates on each thread.

Definition at line 70 of file workqueue.c.