| /dports/converters/wkhtmltopdf/qt-5db36ec/tests/auto/qthreadpool/ |
| H A D | tst_qthreadpool.cpp | 312 QThreadPool threadPool; in threadRecycling() local
358 QThreadPool threadPool; in expiryTimeout() local
394 QThreadPool threadPool; in expiryTimeoutRace() local
500 QThreadPool threadPool; in setMaxThreadCountStartsAndStopsThreads() local
504 threadPool.start(task); in setMaxThreadCountStartsAndStopsThreads()
508 threadPool.start(task); in setMaxThreadCountStartsAndStopsThreads()
516 threadPool.start(task); in setMaxThreadCountStartsAndStopsThreads()
520 threadPool.start(task); in setMaxThreadCountStartsAndStopsThreads()
525 threadPool.start(task); in setMaxThreadCountStartsAndStopsThreads()
526 threadPool.start(task); in setMaxThreadCountStartsAndStopsThreads()
[all …]
|
| /dports/devel/raknet/raknet-3.9.2_10,1/Source/ |
| H A D | FunctionThread.cpp | 31 threadPool.StartThreads(numThreads, 0, 0, 0); in StartThreads()
42 threadPool.StopThreads(); in StopThreads()
54 while (threadPool.HasOutputFast() && threadPool.HasOutput()) in CallResultHandlers()
56 functorAndResult = threadPool.GetOutput(); in CallResultHandlers()
65 threadPool.LockInput(); in CancelFunctorsWithContext()
66 for (i=0; i < threadPool.InputSize(); i++) in CancelFunctorsWithContext()
75 threadPool.ClearInput(); in CancelFunctorsWithContext()
76 threadPool.UnlockInput(); in CancelFunctorsWithContext()
87 threadPool.LockInput(); in CancelInput()
94 threadPool.ClearInput(); in CancelInput()
[all …]
|
| H A D | ThreadPool.h | 212 if (threadPool->perThreadDataFactory) in RAK_THREAD_DECLARATION()
215 perThreadData=threadPool->threadDataInterface->PerThreadFactory(threadPool->tdiContext); in RAK_THREAD_DECLARATION()
221 ++threadPool->numThreadsRunning; in RAK_THREAD_DECLARATION()
233 threadPool->runThreadsMutex.Lock(); in RAK_THREAD_DECLARATION()
234 if (threadPool->runThreads==false) in RAK_THREAD_DECLARATION()
239 threadPool->runThreadsMutex.Unlock(); in RAK_THREAD_DECLARATION()
242 ++threadPool->numThreadsWorking; in RAK_THREAD_DECLARATION()
247 threadPool->inputQueueMutex.Lock(); in RAK_THREAD_DECLARATION()
267 --threadPool->numThreadsWorking; in RAK_THREAD_DECLARATION()
273 --threadPool->numThreadsRunning; in RAK_THREAD_DECLARATION()
[all …]
|
| H A D | SendToThread.cpp | 15 …adPool<SendToThread::SendToThreadBlock*,SendToThread::SendToThreadBlock*> SendToThread::threadPool; member in SendToThread
38 threadPool.StartThreads(1,0); in AddRef()
47 threadPool.StopThreads(); in Deref()
48 RakAssert(threadPool.NumThreadsWorking()==0); in Deref()
52 for (i=0; i < threadPool.InputSize(); i++) in Deref()
54 info = threadPool.GetInputAtIndex(i); in Deref()
57 threadPool.ClearInput(); in Deref()
69 threadPool.AddInput(SendToWorkerThread,threadedSend); in ProcessBlock()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/ |
| H A D | Engine.java | 45 private volatile Executor threadPool; field in Engine
51 Executor getExecutor() { return threadPool; } in getExecutor()
53 public Engine(String id, Executor threadPool) { in Engine() argument
54 this(id, ContainerResolver.getDefault().getContainer(), threadPool); in Engine()
57 public Engine(String id, Container container, Executor threadPool) { in Engine() argument
59 this.threadPool = threadPool != null ? wrap(threadPool) : null; in Engine()
71 public void setExecutor(Executor threadPool) { in setExecutor() argument
72 this.threadPool = threadPool != null ? wrap(threadPool) : null; in setExecutor()
76 if(threadPool==null) { in addRunnable()
78 threadPool = wrap(Executors.newCachedThreadPool(new DaemonThreadFactory())); in addRunnable()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/ |
| H A D | Engine.java | 45 private volatile Executor threadPool; field in Engine
51 Executor getExecutor() { return threadPool; } in getExecutor()
53 public Engine(String id, Executor threadPool) { in Engine() argument
54 this(id, ContainerResolver.getDefault().getContainer(), threadPool); in Engine()
57 public Engine(String id, Container container, Executor threadPool) { in Engine() argument
59 this.threadPool = threadPool != null ? wrap(threadPool) : null; in Engine()
71 public void setExecutor(Executor threadPool) { in setExecutor() argument
72 this.threadPool = threadPool != null ? wrap(threadPool) : null; in setExecutor()
76 if(threadPool==null) { in addRunnable()
78 threadPool = wrap(Executors.newCachedThreadPool(new DaemonThreadFactory())); in addRunnable()
[all …]
|
| /dports/devel/raknet/raknet-3.9.2_10,1/DependentExtensions/Autopatcher/ |
| H A D | AutopatcherServer.cpp | 56 threadPool.StartThreads(numThreads, 0); in StartThreads()
156 threadPool.StopThreads(); in Clear()
161 threadPool.ClearInput(); in Clear()
168 threadPool.ClearOutput(); in Clear()
187 threadPool.LockInput(); in RemoveFromThreadPool()
188 while (i < threadPool.InputSize()) in RemoveFromThreadPool()
193 threadPool.RemoveInputAtIndex(i); in RemoveFromThreadPool()
198 threadPool.UnlockInput(); in RemoveFromThreadPool()
201 threadPool.LockOutput(); in RemoveFromThreadPool()
202 while (i < threadPool.OutputSize()) in RemoveFromThreadPool()
[all …]
|
| /dports/misc/openvdb/openvdb-9.0.0/nanovdb/nanovdb/util/ |
| H A D | Invoke.h | 38 void parallel_invoke(std::vector<std::thread> &threadPool, const Func &taskFunc) { in parallel_invoke() argument
39 threadPool.emplace_back(taskFunc); in parallel_invoke()
44 void parallel_invoke(std::vector<std::thread> &threadPool, const Func &taskFunc1, Rest... taskFuncN… in parallel_invoke() argument
45 threadPool.emplace_back(taskFunc1); in parallel_invoke()
46 parallel_invoke(threadPool, taskFuncN...); in parallel_invoke()
71 std::vector<std::thread> threadPool; in invoke()
72 threadPool.emplace_back(taskFunc1); in invoke()
73 parallel_invoke(threadPool, taskFuncN...); in invoke()
74 for (auto &t : threadPool) t.join(); in invoke()
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.bundles/bundles/org.eclipse.equinox.util/src/org/eclipse/equinox/internal/util/impl/tpt/threadpool/ |
| H A D | ThreadPoolFactoryImpl.java | 33 public static ThreadPoolManagerImpl threadPool; field in ThreadPoolFactoryImpl
42 threadPool = ThreadPoolManagerImpl.getThreadPool(); in ThreadPoolFactoryImpl()
64 if (threadPool == null) in getInstance()
70 ThreadPoolManagerImpl tmp = threadPool; in stopThreadPool()
71 threadPool = null; in stopThreadPool()
77 if (threadPool == null) in getThreadPool()
102 ThreadPoolManagerImpl tmp = threadPool; in execute0()
135 ThreadPoolManagerImpl tmp = threadPool; in getExecutor()
156 threadPool.waiting.addJob(job); in finished()
164 if (threadPool != null) { in reset()
[all …]
|
| /dports/science/InsightToolkit/ITK-5.0.1/Modules/Core/Common/src/ |
| H A D | itkThreadPool.cxx | 176 ThreadPool* threadPool = m_PimplGlobals->m_ThreadPoolInstance.GetPointer(); in ThreadExecute() local
184 threadPool->m_Condition.wait( mutexHolder, in ThreadExecute()
185 [threadPool] in ThreadExecute()
187 return threadPool->m_Stopping || !threadPool->m_WorkQueue.empty(); in ThreadExecute()
190 if ( threadPool->m_Stopping && threadPool->m_WorkQueue.empty() ) in ThreadExecute()
194 task = std::move( threadPool->m_WorkQueue.front() ); in ThreadExecute()
195 threadPool->m_WorkQueue.pop_front(); in ThreadExecute()
|
| /dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/test/bench/simple-sa/ |
| H A D | complex-tp.cfg | 14 <threadPool>
25 </threadPool>
36 # <threadPool>
38 # </threadPool>
46 <threadPool>
48 </threadPool>
|
| H A D | const-cpu-tp.cfg | 14 <threadPool>
25 </threadPool>
36 <threadPool>
38 </threadPool>
46 <threadPool>
48 </threadPool>
|
| H A D | sleep-tp.cfg | 14 <threadPool>
25 </threadPool>
36 <threadPool>
38 </threadPool>
46 <threadPool>
48 </threadPool>
|
| H A D | fileio-tp.cfg | 14 <threadPool>
25 </threadPool>
36 <threadPool>
38 </threadPool>
46 <threadPool>
48 </threadPool>
|
| H A D | exp-cpu-sched-rtcon.cfg | 10 <threadPool>
21 </threadPool>
39 <threadPool>
41 </threadPool>
52 <threadPool>
54 </threadPool>
|
| H A D | exp-cpu-tp.cfg | 10 <threadPool>
21 </threadPool>
39 <threadPool>
41 </threadPool>
52 <threadPool>
54 </threadPool>
|
| /dports/graphics/blend2d/blend2d-592d1ba52672bbf6365aba476bfe26b7bd2dfab8/src/blend2d/raster/ |
| H A D | rasterworkermanager.cpp | 40 BLThreadPool* threadPool = nullptr; in init() local
42 threadPool = blThreadPoolCreate(); in init()
43 if (!threadPool) in init()
47 threadPool = blThreadPoolGlobal(); in init()
58 uint32_t n = threadPool->acquireThreads(workerThreads, threadCount, acquireFlags); in init()
80 threadPool->release(); in init()
89 _threadPool = threadPool; in init()
|
| /dports/graphics/xpdf4/xpdf-4.03/xpdf/ |
| H A D | TileCache.cc | 279 delete threadPool; in ~TileCache()
289 threadPool->lockMutex(); in setActiveTileList()
325 threadPool->unlockMutex(); in setActiveTileList()
328 threadPool->jobAdded(); in setActiveTileList()
337 threadPool->lockMutex(); in getTileBitmap()
340 threadPool->unlockMutex(); in getTileBitmap()
352 threadPool->unlockMutex(); in getTileBitmap()
436 threadPool->lockMutex(); in flushCache()
460 threadPool->unlockMutex(); in flushCache()
542 threadPool->lockMutex(); in rasterizeTile()
[all …]
|
| /dports/graphics/xpdf/xpdf-4.03/xpdf/ |
| H A D | TileCache.cc | 279 delete threadPool; in ~TileCache()
289 threadPool->lockMutex(); in setActiveTileList()
325 threadPool->unlockMutex(); in setActiveTileList()
328 threadPool->jobAdded(); in setActiveTileList()
337 threadPool->lockMutex(); in getTileBitmap()
340 threadPool->unlockMutex(); in getTileBitmap()
352 threadPool->unlockMutex(); in getTileBitmap()
436 threadPool->lockMutex(); in flushCache()
460 threadPool->unlockMutex(); in flushCache()
542 threadPool->lockMutex(); in rasterizeTile()
[all …]
|
| /dports/graphics/blender/blender-2.91.0/extern/audaspace/bindings/python/ |
| H A D | PyThreadPool.cpp | 37 self->threadPool = new std::shared_ptr<aud::ThreadPool>(new aud::ThreadPool(nThreads)); in ThreadPool_new()
53 if(self->threadPool) in ThreadPool_dealloc()
54 delete reinterpret_cast<std::shared_ptr<aud::ThreadPool>*>(self->threadPool); in ThreadPool_dealloc()
112 AUD_API ThreadPoolP* checkThreadPool(PyObject* threadPool) in checkThreadPool() argument
114 if(!PyObject_TypeCheck(threadPool, &ThreadPoolType)) in checkThreadPool()
120 return (ThreadPoolP*)threadPool; in checkThreadPool()
|
| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/core/util/ |
| H A D | ThreadPool.cpp | 30 static ThreadPoolPtr threadPool; in getInstance() local
31 if (!threadPool) { in getInstance()
32 threadPool = newLucene<ThreadPool>(); in getInstance()
33 CycleCheck::addStatic(threadPool); in getInstance()
35 return threadPool; in getInstance()
|
| /dports/www/jetty9/jetty-distribution-9.4.29.v20200521/demo-base/start.d/ |
| H A D | threadpool.ini | 10 #jetty.threadPool.minThreads=10
13 #jetty.threadPool.maxThreads=200
16 # jetty.threadPool.reservedThreads=-1
19 #jetty.threadPool.idleTimeout=60000
22 #jetty.threadPool.detailedDump=false
|
| /dports/graphics/geoserver/geoserver-2.20.1/modules/ |
| H A D | threadpool.mod | 11 jetty.threadPool.minThreads=10
14 jetty.threadPool.maxThreads=200
17 #jetty.threadPool.reservedThreads=-1
20 jetty.threadPool.idleTimeout=60000
23 #jetty.threadPool.detailedDump=false
|
| /dports/security/bastillion/Bastillion-jetty/jetty_bastillion/modules/ |
| H A D | threadpool.mod | 13 #jetty.threadPool.minThreads=10
16 #jetty.threadPool.maxThreads=200
19 # jetty.threadPool.reservedThreads=-1
22 #jetty.threadPool.idleTimeout=60000
25 #jetty.threadPool.detailedDump=false
|
| /dports/www/jetty9/jetty-distribution-9.4.29.v20200521/modules/ |
| H A D | threadpool.mod | 13 #jetty.threadPool.minThreads=10
16 #jetty.threadPool.maxThreads=200
19 # jetty.threadPool.reservedThreads=-1
22 #jetty.threadPool.idleTimeout=60000
25 #jetty.threadPool.detailedDump=false
|