wp_worker Struct Reference

This class represents a worker that is called from within the pool. More...

Collaboration diagram for wp_worker:

Public Member Functions
	wp_worker (worker_state_observer &observer)
	~wp_worker ()
void *	pop (wp_task_data *)
void	push (wp_task_data *)
void	run ()

Static Public Member Functions
static void *	enter_loop (void *args)

Public Attributes
queue< wp_task_data * >	m_data
pthread_mutex_t	m_lock
worker_state_observer &	m_state_observer
pthread_cond_t	m_task_completed_cv
pthread_cond_t	m_task_ready_cv
pthread_t	m_thread_id

Detailed Description

This class represents a worker that is called from within the pool.

Definition at line 79 of file worker.cpp.

Constructor & Destructor Documentation

wp_worker()

wp_worker::wp_worker ( worker_state_observer & observer )

inline

Definition at line 80 of file worker.cpp.

                                                   :
                m_state_observer(observer)
        {
                int ret;
                ret = pthread_mutex_init(&m_lock, NULL);
                assert(ret == 0);
                ret = pthread_cond_init(&m_task_ready_cv, NULL);
                assert(ret == 0);
                ret = pthread_cond_init(&m_task_completed_cv, NULL);
                assert(ret == 0);
 
                ret = pthread_create(&m_thread_id, NULL, wp_worker::enter_loop, this);
                assert(ret == 0);
        }

References enter_loop(), m_lock, m_task_completed_cv, m_task_ready_cv, and m_thread_id.

Here is the call graph for this function:

~wp_worker()

wp_worker::~wp_worker ( )

inline

Definition at line 94 of file worker.cpp.

                     {
                wp_task_data *poisoned = new wp_task_data(NULL, NULL, this, false);
                this->push(poisoned);
 
                pthread_join(m_thread_id, NULL);
                pthread_mutex_destroy(&m_lock);
                pthread_cond_destroy(&m_task_ready_cv);
                pthread_cond_destroy(&m_task_completed_cv);
        }

References m_lock, m_task_completed_cv, m_task_ready_cv, m_thread_id, and push().

Here is the call graph for this function:

Member Function Documentation

enter_loop()

void * wp_worker::enter_loop ( void * args )

static

Definition at line 118 of file worker.cpp.

                                      {
        set_thread_name("worker");
        wp_worker *instance = (wp_worker *) args;
        instance->run();
 
        return NULL;
}

References instance, and set_thread_name().

Referenced by wp_worker().

Here is the call graph for this function:

pop()

void * wp_worker::pop

(

wp_task_data *

d

)

Definition at line 165 of file worker.cpp.

                                    {
        void *res = NULL;
 
        pthread_mutex_lock(&m_lock);
        while(!d->m_returned) {
                pthread_cond_wait(&m_task_completed_cv, &m_lock);
        }
        res = d->m_result;
        delete d;
        pthread_mutex_unlock(&m_lock);
 
        return res;
}

References m_lock, wp_task_data::m_result, wp_task_data::m_returned, and m_task_completed_cv.

Referenced by worker_pool::wait_task().

push()

void wp_worker::push

(

wp_task_data *

data

)

Definition at line 157 of file worker.cpp.

                                       {
        pthread_mutex_lock(&m_lock);
        assert(m_data.size() == 0);
        m_data.push(data);
        pthread_mutex_unlock(&m_lock);
        pthread_cond_signal(&m_task_ready_cv);
}

References m_data, m_lock, and m_task_ready_cv.

Referenced by ~wp_worker(), and worker_pool::run_async().

run()

void wp_worker::run

(

)

Definition at line 126 of file worker.cpp.

                    {
        while(1) {
                struct wp_task_data *data;
                pthread_mutex_lock(&m_lock);
                while(m_data.empty()) {
                        pthread_cond_wait(&m_task_ready_cv, &m_lock);
                }
                data = m_data.front();
                m_data.pop();
                pthread_mutex_unlock(&m_lock);
 
                // poisoned pill
                if(data->m_task == NULL) {
                        delete data;
                        return;
                }
 
                void *res = data->m_task(data->m_data);
 
                pthread_mutex_lock(&m_lock);
                data->m_result = res;
                data->m_returned = true;
                pthread_cond_signal(&m_task_completed_cv);
                m_state_observer.notify(this);
                if (data->m_detached) {
                        delete data;
                }
                pthread_mutex_unlock(&m_lock);
        }
}

References wp_task_data::m_data, m_data, wp_task_data::m_detached, m_lock, wp_task_data::m_result, wp_task_data::m_returned, m_state_observer, wp_task_data::m_task, m_task_completed_cv, m_task_ready_cv, and worker_state_observer::notify().

Here is the call graph for this function:

Member Data Documentation

m_data

queue<wp_task_data*> wp_worker::m_data

Definition at line 109 of file worker.cpp.

Referenced by push(), and run().

m_lock

pthread_mutex_t wp_worker::m_lock

Definition at line 110 of file worker.cpp.

Referenced by wp_worker(), ~wp_worker(), pop(), push(), and run().

m_state_observer

worker_state_observer& wp_worker::m_state_observer

Definition at line 115 of file worker.cpp.

Referenced by run().

m_task_completed_cv

pthread_cond_t wp_worker::m_task_completed_cv

Definition at line 112 of file worker.cpp.

Referenced by wp_worker(), ~wp_worker(), pop(), and run().

m_task_ready_cv

pthread_cond_t wp_worker::m_task_ready_cv

Definition at line 111 of file worker.cpp.

Referenced by wp_worker(), ~wp_worker(), push(), and run().

m_thread_id

pthread_t wp_worker::m_thread_id

Definition at line 113 of file worker.cpp.

Referenced by wp_worker(), and ~wp_worker().

---

The documentation for this struct was generated from the following file:

• src/utils/worker.cpp