Changeset 421 for experimental/Threading/Threading/SimHost.cpp

Timestamp:

Oct 20, 2012, 1:07:25 AM (12 years ago)

Author:

Torben Dannhauer

Message:

 

File:

• experimental/Threading/Threading/SimHost.cpp (modified) (4 diffs)

experimental/Threading/Threading/SimHost.cpp

@@ -25 +25 @@
 SimHost::~SimHost()
 {
-        _channelWorker.clear();
+        //_channelWorker.clear();
 }
 
@@ -37 +37 @@
         for(int i=0; i<numThreads-1; ++i)
         {
-                osg::ref_ptr<ChannelWorker> worker = new ChannelWorker(numThreads, syncBarrier);
+                osg::ref_ptr<ChannelWorker> worker = new ChannelWorker();
                 _channelWorker.push_back(worker);
         }
@@ -58 +58 @@
         {
                 int status;
-                        
-                //thread->addObserver(&observer);
+                
                 //thread->setStackSize(1024*256);
                 status = _channelWorker[i]->start();
@@ -72 +71 @@
     for(int i=0;i<static_cast<int>(_channelWorker.size());++i)
         {
-                _channelWorker[i]->setDone(true);
-                //_channelWorker[i]->cancel();          // Seems to be wrong
+                //_channelWorker[i]->setDone(true);     // non blocking
+                _channelWorker[i]->cancel();    // Blocking
         }
+
+        for(int i=0;i<100000000;i++)
+                OSG_ALWAYS<<"";
 
         //syncBarrier.block(numThreads);  // Block until all threads are ready