version 0.3.0

[fms.git] / src / pthreadwrapper / threadedexecutor.cpp

diff --git a/src/pthreadwrapper/threadedexecutor.cpp b/src/pthreadwrapper/threadedexecutor.cpp
deleted file mode 100644 (file)
index 52377b5..0000000
--- a/src/pthreadwrapper/threadedexecutor.cpp
+++ /dev/null
@@ -1,59 +0,0 @@
-#include "../../include/pthreadwrapper/threadedexecutor.h"\r
-\r
-#ifdef XMEM\r
-       #include <xmem.h>\r
-#endif\r
-\r
-namespace PThread\r
-{\r
-\r
-ThreadedExecutor::~ThreadedExecutor()\r
-{\r
-       for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)\r
-       {\r
-               (*i)->Cancel();\r
-               (*i)->Join();\r
-               delete (*i);\r
-       }\r
-}\r
-\r
-void ThreadedExecutor::Cancel()\r
-{\r
-       for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); i++)\r
-       {\r
-               (*i)->Cancel(); \r
-       }\r
-}\r
-\r
-void ThreadedExecutor::CleanupFinished()\r
-{\r
-       for(std::vector<Thread *>::iterator i=m_threads.begin(); i!=m_threads.end(); )\r
-       {\r
-               if((*i)->IsRunning()==false)\r
-               {\r
-                       delete (*i);\r
-                       i=m_threads.erase(i);\r
-               }\r
-               else\r
-               {\r
-                       i++;\r
-               }\r
-       }\r
-}\r
-\r
-void ThreadedExecutor::Execute(Runnable *runnable)\r
-{\r
-       CleanupFinished();\r
-       m_threads.push_back(new Thread(runnable));      \r
-}\r
-\r
-void ThreadedExecutor::Join()\r
-{\r
-       for(std::vector<Thread *>::iterator     i=m_threads.begin(); i!=m_threads.end(); i++)\r
-       {\r
-               (*i)->Join();\r
-       }\r
-       CleanupFinished();\r
-}\r
-\r
-}      // namespace\r