worker_pool Class Reference

Inheritance diagram for worker_pool:

Collaboration diagram for worker_pool:

Public Member Functions
	worker_pool ()
	~worker_pool ()
void	notify (wp_worker *w)
task_result_handle_t	run_async (runnable_t task, void *data, bool detached)
void *	wait_task (task_result_handle_t handle)
Public Member Functions inherited from worker_state_observer
virtual	~worker_state_observer ()

Private Attributes
set< wp_worker * >	m_empty_workers
pthread_mutex_t	m_lock
set< wp_worker * >	m_occupied_workers
pthread_cond_t	m_worker_finished

Detailed Description

Definition at line 183 of file worker.cpp.

Constructor & Destructor Documentation

worker_pool()

worker_pool::worker_pool ( )

inline

Definition at line 186 of file worker.cpp.

                              {
                        pthread_mutex_init(&m_lock, NULL);
                        pthread_cond_init(&m_worker_finished, NULL);
                }

References m_lock, and m_worker_finished.

~worker_pool()

worker_pool::~worker_pool ( )

inline

Definition at line 191 of file worker.cpp.

                               {
                        pthread_mutex_lock(&m_lock);
                        while (m_occupied_workers.size() > 0) {
                                pthread_cond_wait(&m_worker_finished, &m_lock);
                        }
                        pthread_mutex_unlock(&m_lock);
 
                        for_each(m_empty_workers.begin(),
                                        m_empty_workers.end(), func_delete);
                        pthread_cond_destroy(&m_worker_finished);
                        pthread_mutex_destroy(&m_lock);
                }

References func_delete(), m_empty_workers, m_lock, m_occupied_workers, and m_worker_finished.

Here is the call graph for this function:

Member Function Documentation

notify()

void worker_pool::notify ( wp_worker * w )

inlinevirtual

Implements worker_state_observer.

Definition at line 204 of file worker.cpp.

                                          {
                        pthread_mutex_lock(&m_lock);
                        m_occupied_workers.erase(w);
                        m_empty_workers.insert(w);
                        pthread_mutex_unlock(&m_lock);
                        pthread_cond_signal(&m_worker_finished);
                }

References m_empty_workers, m_lock, m_occupied_workers, and m_worker_finished.

run_async()

task_result_handle_t worker_pool::run_async	(	runnable_t	task,
		void *	data,
		bool	detached )

Todo

: really weird - it seems like that 'it' instead of 'w' caused some problems

Definition at line 222 of file worker.cpp.

{
        wp_worker *w;
        pthread_mutex_lock(&m_lock);
        if(m_empty_workers.empty()) {
                m_empty_workers.insert(new wp_worker(*this));
        }
        set<wp_worker*>::iterator it = m_empty_workers.begin();
        assert(it != m_empty_workers.end());
        w = *it;
        m_empty_workers.erase(w);
        m_occupied_workers.insert(w);
 
        wp_task_data *d = new wp_task_data(task, data, w, detached);
        w->push(d);
        pthread_mutex_unlock(&m_lock);
 
        return d;
}

References m_empty_workers, m_lock, m_occupied_workers, and wp_worker::push().

Referenced by task_run_async(), and task_run_async_detached().

Here is the call graph for this function:

wait_task()

void * worker_pool::wait_task

(

task_result_handle_t

handle

)

Definition at line 243 of file worker.cpp.

{
        wp_task_data *d = (wp_task_data *) handle;
        wp_worker *w = d->m_w;
        return w->pop(d);
}

References wp_task_data::m_w, and wp_worker::pop().

Referenced by wait_task().

Here is the call graph for this function:

Member Data Documentation

m_empty_workers

set<wp_worker*> worker_pool::m_empty_workers

private

Definition at line 216 of file worker.cpp.

Referenced by ~worker_pool(), notify(), and run_async().

m_lock

pthread_mutex_t worker_pool::m_lock

private

Definition at line 218 of file worker.cpp.

Referenced by worker_pool(), ~worker_pool(), notify(), and run_async().

m_occupied_workers

set<wp_worker*> worker_pool::m_occupied_workers

private

Definition at line 217 of file worker.cpp.

Referenced by ~worker_pool(), notify(), and run_async().

m_worker_finished

pthread_cond_t worker_pool::m_worker_finished

private

Definition at line 219 of file worker.cpp.

Referenced by worker_pool(), ~worker_pool(), and notify().

---

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

• src/utils/worker.cpp