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

Timestamp:

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

Author:

Torben Dannhauer

Message:

 

File:

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

experimental/Threading/Threading/SimHost.cpp

@@ -33 +33 @@
         OpenThreads::Barrier syncBarrier;
 
-        // Create ChannelWorkers
-        OSG_ALWAYS<<"Creating ChannelWorkers..."<<std::endl;
+        // Create IG Connectors
+        OSG_ALWAYS<<"Creating IG Connectors..."<<std::endl;
         for(int i=0; i<numThreads-1; ++i)
         {
-                osg::ref_ptr<ChannelWorker> worker = new ChannelWorker();
-                _channelWorker.push_back(worker);
+                osg::ref_ptr<ThreadedWorker> threadObject = new ThreadedWorker();
+                osg::ref_ptr<IGConnector> IGCon = new IGConnector();
+                threadObject->setThreadWorker(IGCon);
+                _threadObjects.push_back(threadObject);
+                _IGConnectors.push_back(IGCon);
         }
         OSG_ALWAYS<<"...done."<<std::endl;
@@ -55 +58 @@
 {
         // Launch threads
-    for(int i=0;i<static_cast<int>(_channelWorker.size());++i)
+    for(int i=0;i<static_cast<int>(_threadObjects.size());++i)
         {
                 int status;
                 
                 //thread->setStackSize(1024*256);
-                status = _channelWorker[i]->start();
+                status = _threadObjects[i]->start();
                 assert(status == 0);
         }
 
         // Do something in the main thread
-        for(int i=0;i<10000000;i++)
-                OSG_ALWAYS<<"";
+                for(int i=0;i<10000000;i++)     OSG_ALWAYS<<"";
         
         // Signal threads to finish
-    for(int i=0;i<static_cast<int>(_channelWorker.size());++i)
+    for(int i=0;i<static_cast<int>(_threadObjects.size());++i)
         {
-                //_channelWorker[i]->setDone(true);     // non blocking
-                _channelWorker[i]->cancel();    // Blocking
+                //_threadObjects[i]->setDone(true);     // non blocking
+                _threadObjects[i]->cancel();    // Blocking
         }
 
@@ -78 +80 @@
                 OSG_ALWAYS<<"";
 
-        //syncBarrier.block(numThreads);  // Block until all threads are ready
 }