1 #include "../../include/threadwrapper/threadedexecutor.h"
\r
3 ThreadedExecutor::~ThreadedExecutor()
\r
5 for(std::vector<CancelableThread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)
\r
13 void ThreadedExecutor::Cancel()
\r
15 for(std::vector<CancelableThread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)
\r
17 if((*i)->isRunning())
\r
24 void ThreadedExecutor::CleanupCompleted()
\r
26 for(std::vector<CancelableThread *>::iterator i=m_threads.begin(); i!=m_threads.end(); )
\r
28 if((*i)->isRunning()==false)
\r
31 i=m_threads.erase(i);
\r
40 void ThreadedExecutor::Join()
\r
43 for(std::vector<CancelableThread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)
\r
45 if((*i)->isRunning())
\r
53 void ThreadedExecutor::Start(CancelableRunnable *runnable)
\r
55 m_threads.push_back(new CancelableThread(runnable));
\r