Changeset 425 for experimental/Threading/Threading/ThreadedWorker.cpp

Timestamp:

Oct 21, 2012, 12:05:47 AM (12 years ago)

Author:

Torben Dannhauer

Message:

 

File:

• experimental/Threading/Threading/ThreadedWorker.cpp (modified) (3 diffs)

experimental/Threading/Threading/ThreadedWorker.cpp

@@ -1 +1 @@
 #include "ThreadedWorker.h"
 #include <osg/Notify>
+#include <OpenThreads/ScopedLock>
 
 
@@ -19 +20 @@
 
         // Do the work
-        int i=0;
         do
         {
-                OSG_ALWAYS<<"ID "<<getThreadId()<<" :: itr "<<i++<<std::endl;
+                OpenThreads::ScopedLock<OpenThreads::Mutex> lock(_threadWorkerMutex);
 
-                // Place Holder
-                for(int i=0;i<100;i++)
-                OSG_ALWAYS<<"";
-
-        } while (!testCancel() && !_done);      // repeat as long it is canceld or set as Done
+                if( _threadWorker.valid() )
+                        (*_threadWorker)(this);
+                
+        } while (_threadWorker!=NULL && !testCancel() && !_done);       // repeat as long as a functor is set and it is not canceled or set as Done
 }
 
@@ -60 +59 @@
     return 0;
 }
+
+void ThreadedWorker::setThreadWorker( ThreadWorkerBase* tworker)
+{
+        OpenThreads::ScopedLock<OpenThreads::Mutex> lock(_threadWorkerMutex);
+
+        _threadWorker = tworker;
+}