some fixes

This commit is contained in:
Martin Pulec
2013-04-19 11:03:19 +02:00
parent f387b11eef
commit 7ebedcdb94
3 changed files with 5 additions and 5 deletions

View File

@@ -208,7 +208,8 @@ task_result_handle_t worker_pool::run_async(task_t task, void *data)
set<worker*>::iterator it = m_empty_workers.begin();
assert(it != m_empty_workers.end());
w = *it;
m_empty_workers.erase(it);
/// @todo: really weird - it seems like that 'it' instead of 'w' caused some problems
m_empty_workers.erase(w);
m_occupied_workers.insert(w);
pthread_mutex_unlock(&m_lock);
@@ -227,7 +228,7 @@ class worker_pool instance;
task_result_handle_t task_run_async(task_t task, void *data)
{
instance.run_async(task, data);
return instance.run_async(task, data);
}
void *wait_task(task_result_handle_t handle)