1 #include "../../include/pthreadwrapper/threadedexecutor.h"
\r
10 ThreadedExecutor::~ThreadedExecutor()
\r
12 for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)
\r
20 void ThreadedExecutor::Cancel()
\r
22 for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)
\r
28 void ThreadedExecutor::CleanupFinished()
\r
30 for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); )
\r
32 if((*i)->IsRunning()==false)
\r
35 i=m_threads.erase(i);
\r
44 void ThreadedExecutor::Execute(Runnable *runnable)
\r
47 m_threads.push_back(new Thread(runnable));
\r
50 void ThreadedExecutor::Join()
\r
52 for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)
\r