Changeset 845

Timestamp:

01/17/08 20:20:29

Author:

robert

Message:

Added throttling of the calls to ThreadPool?::run to limit the number of operations
that the queue will permit.

Files:

• trunk/include/vpb/ThreadPool (modified) (1 diff)
• trunk/src/vpb/ThreadPool.cpp (modified) (2 diffs)

trunk/include/vpb/ThreadPool

@@ -72 +72 @@
-        bool                                _done;
-        osg::ref_ptr<BlockOperation>        _blockOp;
+        
+        unsigned int                         _maxNumberOfOperationsInQueue;
-       
-};

trunk/src/vpb/ThreadPool.cpp

@@ -45 +45 @@
-
-    osg::GraphicsContext* sharedContext = 0;
+
+    _maxNumberOfOperationsInQueue = 512;
-
-    for(unsigned int i=0; i<_numThreads; ++i)
@@ -143 +145 @@
-    }
-    
+    while (_operationQueue->getNumOperationsInQueue() >= _maxNumberOfOperationsInQueue)
+    {
+        log(osg::NOTICE,"ThreadPool::run() Waiting for operation queue to clear.");
+        OpenThreads::Thread::YieldCurrentThread();
+    }
+    
-    _operationQueue->add(op);
-}