Home
last modified time | relevance | path

Searched refs:myThreadPool (Results 1 – 8 of 8) sorted by relevance

/dports/cad/sumo/sumo-1.2.0/src/utils/router/
H A DCHRouterWrapper.h114 while ((int)myThreadPool.size() < myMaxNumInstances) {
115 new FXWorkerThread(myThreadPool);
130 if (myThreadPool.size() > 0) {
131 …myThreadPool.add(new ComputeHierarchyTask(myRouters[svc].back(), vehicle, myBegin + i * myWeightPe…
136 if (myThreadPool.size() > 0) {
137 myThreadPool.waitAll();
169 FXWorkerThread::Pool myThreadPool;
/dports/cad/sumo/sumo-1.2.0/src/microsim/
H A DMSEdgeControl.cpp98 while (myThreadPool.size() < MSGlobals::gNumSimThreads) { in planMovements()
99 new FXWorkerThread(myThreadPool); in planMovements()
124 … myThreadPool.add((*i)->getPlanMoveTask(t), (*i)->getRNGIndex() % myThreadPool.size()); in planMovements()
135 myThreadPool.waitAll(false); in planMovements()
170 … myThreadPool.add(lane->getExecuteMoveTask(t), lane->getRNGIndex() % myThreadPool.size()); in executeMovements()
172 myThreadPool.waitAll(false); in executeMovements()
232 … myThreadPool.add(lane->getLaneChangeTask(t), lane->getRNGIndex() % myThreadPool.size()); in changeLanes()
261 myThreadPool.waitAll(false); in changeLanes()
H A DMSEdgeControl.h235 FXWorkerThread::Pool myThreadPool; variable
/dports/cad/sumo/sumo-1.2.0/src/microsim/devices/
H A DMSRoutingEngine.cpp62 FXWorkerThread::Pool MSRoutingEngine::myThreadPool; member in MSRoutingEngine
216 const bool needThread = (myRouter == nullptr && myThreadPool.isFull()); in reroute()
287 if (myThreadPool.size() < numThreads) { in reroute()
288 new WorkerThread(myThreadPool, myRouter); in reroute()
290 if (myThreadPool.size() < numThreads) { in reroute()
294 if (myThreadPool.size() > 0) { in reroute()
295 myThreadPool.add(new RoutingTask(vehicle, currentTime, onInit)); in reroute()
336 if (myThreadPool.size() > 0) { in cleanup()
339 myThreadPool.clear(); in cleanup()
353 if (myThreadPool.size() > 0) { in waitForAll()
[all …]
H A DMSRoutingEngine.h125 myThreadPool.lock(); in lock()
128 myThreadPool.unlock(); in unlock()
131 return myThreadPool.size() > 0; in isParallel()
233 static FXWorkerThread::Pool myThreadPool; variable
/dports/cad/sumo/sumo-1.2.0/src/router/
H A DRONet.cpp270 if (myThreadPool.size() > 0) { in cleanup()
271 myThreadPool.clear(); in cleanup()
510 if (myThreadPool.size() > 0) { in createBulkRouteRequests()
513 myThreadPool.add(new BulkmodeTask(true), workerIndex); in createBulkRouteRequests()
517 myThreadPool.add(new BulkmodeTask(false), workerIndex); in createBulkRouteRequests()
519 if (workerIndex == (int)myThreadPool.size()) { in createBulkRouteRequests()
548 while ((int)myThreadPool.size() < maxNumThreads) { in saveAndRemoveRoutesUntil()
549 new WorkerThread(myThreadPool, provider); in saveAndRemoveRoutesUntil()
562 const int numThreads = (int)myThreadPool.size(); in saveAndRemoveRoutesUntil()
567 new WorkerThread(myThreadPool, provider); in saveAndRemoveRoutesUntil()
[all …]
H A DRONet.h412 return myThreadPool; in getThreadPool()
558 FXWorkerThread::Pool myThreadPool;
/dports/cad/opencascade/opencascade-7.6.0/src/RWGltf/
H A DRWGltf_CafReader.cxx44 myThreadPool(theThreadPool) in CafReader_GltfBaseLoadingFunctor()
62 if (myThreadPool.HasThreads()) in operator ()()
84 const OSD_ThreadPool::Launcher& myThreadPool; member in RWGltf_CafReader::CafReader_GltfBaseLoadingFunctor