| /dports/www/firefox-legacy/firefox-52.8.0esr/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/uploaders/ |
| H A D | BatchingUploaderTest.java | 69 private Executor workQueue; field in BatchingUploaderTest
74 workQueue = new MockExecutorService(); in setUp()
85 assertEquals(0, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
86 assertEquals(0, ((MockExecutorService) workQueue).commitPayloads); in testProcessEvenPayloadBatch()
89 assertEquals(1, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
93 assertEquals(1, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
97 assertEquals(2, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
101 assertEquals(2, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
105 assertEquals(3, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
109 assertEquals(3, ((MockExecutorService) workQueue).totalPayloads); in testProcessEvenPayloadBatch()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/mobile/android/services/src/test/java/org/mozilla/gecko/sync/repositories/uploaders/ |
| H A D | BatchingUploaderTest.java | 171 private ExecutorService workQueue; field in BatchingUploaderTest
176 workQueue = new MockExecutorService(); in setUp()
260 assertEquals(0, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
264 assertEquals(1, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
268 assertEquals(1, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
272 assertEquals(2, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
276 assertEquals(3, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
280 assertEquals(3, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
284 assertEquals(4, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
288 assertEquals(4, ((MockExecutorService) workQueue).totalPayloads); in testProcessUnevenPayloadBatch()
[all …]
|
| /dports/converters/wkhtmltopdf/qt-5db36ec/src/3rdparty/webkit/Source/JavaScriptCore/runtime/ |
| H A D | RopeImpl.cpp | 31 void RopeImpl::derefFibersNonRecursive(Vector<RopeImpl*, 32>& workQueue) in derefFibersNonRecursive() argument
39 workQueue.append(nextRope); in derefFibersNonRecursive()
49 Vector<RopeImpl*, 32> workQueue; in destructNonRecursive() local
51 derefFibersNonRecursive(workQueue); in destructNonRecursive()
54 while (!workQueue.isEmpty()) { in destructNonRecursive()
55 RopeImpl* rope = workQueue.last(); in destructNonRecursive()
56 workQueue.removeLast(); in destructNonRecursive()
57 rope->derefFibersNonRecursive(workQueue); in destructNonRecursive()
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/webservices/ipfs/ |
| H A D | ipfstalker.cpp | 68 QQueue<IpfsTalkerAction> workQueue; member in DigikamGenericIpfsPlugin::IpfsTalker::Private
105 return d->workQueue.size(); in workQueueLength()
110 d->workQueue.enqueue(action); in queueWork()
125 while (!d->workQueue.empty()) in cancelAllWork()
127 d->workQueue.dequeue(); in cancelAllWork()
151 if (d->workQueue.empty()) in replyFinished()
167 result.action = &d->workQueue.first(); in replyFinished()
208 emit error(msg, d->workQueue.first()); in replyFinished()
214 d->workQueue.dequeue(); in replyFinished()
265 auto &work = d->workQueue.first(); in doWork()
[all …]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/orbutil/threadpool/ |
| H A D | ThreadPoolImpl.java | 72 private WorkQueue workQueue; field in ThreadPoolImpl
254 return workQueue; in getAnyWorkQueue()
262 return workQueue; in getWorkQueue()
344 synchronized (workQueue) { in createWorkerThread()
382 synchronized (workQueue) { in currentNumberOfThreads()
388 synchronized (workQueue) { in decrementCurrentNumberOfThreads()
394 synchronized (workQueue) { in incrementCurrentNumberOfThreads()
400 synchronized (workQueue) { in numberOfAvailableThreads()
406 synchronized (workQueue) { in numberOfBusyThreads()
412 synchronized (workQueue) { in averageWorkCompletionTime()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/orbutil/threadpool/ |
| H A D | ThreadPoolImpl.java | 72 private WorkQueue workQueue; field in ThreadPoolImpl
254 return workQueue; in getAnyWorkQueue()
262 return workQueue; in getWorkQueue()
344 synchronized (workQueue) { in createWorkerThread()
382 synchronized (workQueue) { in currentNumberOfThreads()
388 synchronized (workQueue) { in decrementCurrentNumberOfThreads()
394 synchronized (workQueue) { in incrementCurrentNumberOfThreads()
400 synchronized (workQueue) { in numberOfAvailableThreads()
406 synchronized (workQueue) { in numberOfBusyThreads()
412 synchronized (workQueue) { in averageWorkCompletionTime()
[all …]
|
| /dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/util/ |
| H A D | ThreadManagerThreadPoolExecutor.java | 14 BlockingQueue<Runnable> workQueue) { in ThreadManagerThreadPoolExecutor() argument
15 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue); in ThreadManagerThreadPoolExecutor()
19 … BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) { in ThreadManagerThreadPoolExecutor() argument
20 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory); in ThreadManagerThreadPoolExecutor()
24 … BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) { in ThreadManagerThreadPoolExecutor() argument
25 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, handler); in ThreadManagerThreadPoolExecutor()
29 …BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) { in ThreadManagerThreadPoolExecutor() argument
30 … super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler); in ThreadManagerThreadPoolExecutor()
|
| /dports/lang/gcc6-aux/gcc-6-20180516/libjava/classpath/external/jsr166/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 472 Runnable next = workQueue.poll(); in addIfUnderMaximumPoolSize()
501 return workQueue.take(); in getTask()
517 Runnable r = workQueue.poll(); in getTask()
522 if (workQueue.isEmpty()) { in getTask()
528 return workQueue.take(); in getTask()
580 if (!workQueue.isEmpty()) { in workerDone()
857 this.workQueue = workQueue; in ThreadPoolExecutor()
888 if (workQueue.offer(command)) in execute()
1122 return workQueue; in getQueue()
1195 int n = workQueue.size(); in setCorePoolSize()
[all …]
|
| /dports/lang/gcc48/gcc-4.8.5/libjava/classpath/external/jsr166/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 472 Runnable next = workQueue.poll(); in addIfUnderMaximumPoolSize()
501 return workQueue.take(); in getTask()
517 Runnable r = workQueue.poll(); in getTask()
522 if (workQueue.isEmpty()) { in getTask()
528 return workQueue.take(); in getTask()
580 if (!workQueue.isEmpty()) { in workerDone()
857 this.workQueue = workQueue; in ThreadPoolExecutor()
888 if (workQueue.offer(command)) in execute()
1122 return workQueue; in getQueue()
1195 int n = workQueue.size(); in setCorePoolSize()
[all …]
|
| /dports/devel/arm-none-eabi-gcc492/gcc-4.9.2/libjava/classpath/external/jsr166/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 472 Runnable next = workQueue.poll(); in addIfUnderMaximumPoolSize()
501 return workQueue.take(); in getTask()
517 Runnable r = workQueue.poll(); in getTask()
522 if (workQueue.isEmpty()) { in getTask()
528 return workQueue.take(); in getTask()
580 if (!workQueue.isEmpty()) { in workerDone()
857 this.workQueue = workQueue; in ThreadPoolExecutor()
888 if (workQueue.offer(command)) in execute()
1122 return workQueue; in getQueue()
1195 int n = workQueue.size(); in setCorePoolSize()
[all …]
|
| /dports/lang/gnat_util/gcc-6-20180516/libjava/classpath/external/jsr166/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 472 Runnable next = workQueue.poll(); in addIfUnderMaximumPoolSize()
501 return workQueue.take(); in getTask()
517 Runnable r = workQueue.poll(); in getTask()
522 if (workQueue.isEmpty()) { in getTask()
528 return workQueue.take(); in getTask()
580 if (!workQueue.isEmpty()) { in workerDone()
857 this.workQueue = workQueue; in ThreadPoolExecutor()
888 if (workQueue.offer(command)) in execute()
1122 return workQueue; in getQueue()
1195 int n = workQueue.size(); in setCorePoolSize()
[all …]
|
| /dports/devel/mingw32-gcc/gcc-4.8.1/libjava/classpath/external/jsr166/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 472 Runnable next = workQueue.poll(); in addIfUnderMaximumPoolSize()
501 return workQueue.take(); in getTask()
517 Runnable r = workQueue.poll(); in getTask()
522 if (workQueue.isEmpty()) { in getTask()
528 return workQueue.take(); in getTask()
580 if (!workQueue.isEmpty()) { in workerDone()
857 this.workQueue = workQueue; in ThreadPoolExecutor()
888 if (workQueue.offer(command)) in execute()
1122 return workQueue; in getQueue()
1195 int n = workQueue.size(); in setCorePoolSize()
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
843 BlockingQueue<Runnable> q = workQueue; in drainQueue()
892 || workQueue.isEmpty())) in addWorker()
1054 workQueue.take(); in getTask()
1298 this.workQueue = workQueue; in ThreadPoolExecutor()
1547 if (workQueue.isEmpty()) in setCorePoolSize()
1731 return workQueue; in getQueue()
1751 boolean removed = workQueue.remove(task); in remove()
1767 final BlockingQueue<Runnable> q = workQueue; in purge()
1861 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
843 BlockingQueue<Runnable> q = workQueue; in drainQueue()
892 || workQueue.isEmpty())) in addWorker()
1054 workQueue.take(); in getTask()
1298 this.workQueue = workQueue; in ThreadPoolExecutor()
1547 if (workQueue.isEmpty()) in setCorePoolSize()
1731 return workQueue; in getQueue()
1751 boolean removed = workQueue.remove(task); in remove()
1767 final BlockingQueue<Runnable> q = workQueue; in purge()
1861 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
843 BlockingQueue<Runnable> q = workQueue; in drainQueue()
892 || workQueue.isEmpty())) in addWorker()
1054 workQueue.take(); in getTask()
1298 this.workQueue = workQueue; in ThreadPoolExecutor()
1547 if (workQueue.isEmpty()) in setCorePoolSize()
1731 return workQueue; in getQueue()
1751 boolean removed = workQueue.remove(task); in remove()
1767 final BlockingQueue<Runnable> q = workQueue; in purge()
1861 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
845 BlockingQueue<Runnable> q = workQueue; in drainQueue()
894 || workQueue.isEmpty())) in addWorker()
1056 workQueue.take(); in getTask()
1300 this.workQueue = workQueue; in ThreadPoolExecutor()
1549 if (workQueue.isEmpty()) in setCorePoolSize()
1733 return workQueue; in getQueue()
1753 boolean removed = workQueue.remove(task); in remove()
1769 final BlockingQueue<Runnable> q = workQueue; in purge()
1863 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 452 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
851 BlockingQueue<Runnable> q = workQueue; in drainQueue()
900 || workQueue.isEmpty())) in addWorker()
1062 workQueue.take(); in getTask()
1308 this.workQueue = workQueue; in ThreadPoolExecutor()
1557 if (workQueue.isEmpty()) in setCorePoolSize()
1741 return workQueue; in getQueue()
1761 boolean removed = workQueue.remove(task); in remove()
1777 final BlockingQueue<Runnable> q = workQueue; in purge()
1871 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
843 BlockingQueue<Runnable> q = workQueue; in drainQueue()
892 || workQueue.isEmpty())) in addWorker()
1054 workQueue.take(); in getTask()
1298 this.workQueue = workQueue; in ThreadPoolExecutor()
1547 if (workQueue.isEmpty()) in setCorePoolSize()
1731 return workQueue; in getQueue()
1751 boolean removed = workQueue.remove(task); in remove()
1767 final BlockingQueue<Runnable> q = workQueue; in purge()
1861 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
845 BlockingQueue<Runnable> q = workQueue; in drainQueue()
894 || workQueue.isEmpty())) in addWorker()
1056 workQueue.take(); in getTask()
1300 this.workQueue = workQueue; in ThreadPoolExecutor()
1549 if (workQueue.isEmpty()) in setCorePoolSize()
1733 return workQueue; in getQueue()
1753 boolean removed = workQueue.remove(task); in remove()
1769 final BlockingQueue<Runnable> q = workQueue; in purge()
1863 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 447 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
845 BlockingQueue<Runnable> q = workQueue; in drainQueue()
894 || workQueue.isEmpty())) in addWorker()
1056 workQueue.take(); in getTask()
1300 this.workQueue = workQueue; in ThreadPoolExecutor()
1549 if (workQueue.isEmpty()) in setCorePoolSize()
1733 return workQueue; in getQueue()
1753 boolean removed = workQueue.remove(task); in remove()
1769 final BlockingQueue<Runnable> q = workQueue; in purge()
1863 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/lang/polyml/polyml-5.8.2/libpolyml/ |
| H A D | gctaskfarm.cpp | 58 workQueue = 0; in GCTaskFarm()
67 free(workQueue); in ~GCTaskFarm()
76 workQueue = (queue_entry*)calloc(qSize, sizeof(queue_entry)); in Initialise()
77 if (workQueue == 0) return false; in Initialise()
132 workQueue[queueIn].task = work; in AddWork()
133 workQueue[queueIn].arg1 = arg1; in AddWork()
134 workQueue[queueIn].arg2 = arg2; in AddWork()
171 gctask work = workQueue[outPos].task; in ThreadFunction()
172 void *arg1 = workQueue[outPos].arg1; in ThreadFunction()
173 void *arg2 = workQueue[outPos].arg2; in ThreadFunction()
[all …]
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.ui/bundles/org.eclipse.core.databinding.observable/src/org/eclipse/core/databinding/observable/ |
| H A D | Realm.java | 125 Queue workQueue = new Queue(); field in Realm
196 synchronized (workQueue) { in asyncExec()
198 workQueue.enqueue(runnable); in asyncExec()
199 workQueue.notifyAll(); in asyncExec()
228 synchronized (workQueue) { in timerExec()
254 synchronized (workQueue) { in ensureWorkerThreadIsRunning()
255 while (workQueue.isEmpty()) { in ensureWorkerThreadIsRunning()
256 workQueue.wait(); in ensureWorkerThreadIsRunning()
258 work = (Runnable) workQueue.dequeue(); in ensureWorkerThreadIsRunning()
|
| /dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/archive/ |
| H A D | Archiver.java | 75 final List<ArchiveCandidate<E>> workQueue = Collections.synchronizedList(new ArrayList<>()); field in Archiver
135 … while ( ( workQueue.size() < maxWorkQueueSize ) // Don't allow the batch to grow to big. in run()
139 workQueue.add( work ); in run()
149 if ( !workQueue.isEmpty() ) in run()
151 final List<E> batch = workQueue.stream() in run()
155 lastProcessed = workQueue.get( workQueue.size() -1 ).createdAt(); in run()
156 … Log.trace( "Stored all produced work in the database. Work size: {}", workQueue.size() ); in run()
157 workQueue.clear(); in run()
239 if ( queue.isEmpty() && workQueue.isEmpty() ) in availabilityETAOnLocalNode()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 448 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
859 BlockingQueue<Runnable> q = workQueue; in drainQueue()
911 ! workQueue.isEmpty())) in addWorker()
1074 workQueue.take(); in getTask()
1322 this.workQueue = workQueue; in ThreadPoolExecutor()
1567 if (workQueue.isEmpty()) in setCorePoolSize()
1746 return workQueue; in getQueue()
1766 boolean removed = workQueue.remove(task); in remove()
1782 final BlockingQueue<Runnable> q = workQueue; in purge()
1876 return n + workQueue.size(); in getTaskCount()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/util/concurrent/ |
| H A D | ThreadPoolExecutor.java | 448 private final BlockingQueue<Runnable> workQueue; field in ThreadPoolExecutor
859 BlockingQueue<Runnable> q = workQueue; in drainQueue()
911 ! workQueue.isEmpty())) in addWorker()
1074 workQueue.take(); in getTask()
1322 this.workQueue = workQueue; in ThreadPoolExecutor()
1567 if (workQueue.isEmpty()) in setCorePoolSize()
1746 return workQueue; in getQueue()
1766 boolean removed = workQueue.remove(task); in remove()
1782 final BlockingQueue<Runnable> q = workQueue; in purge()
1876 return n + workQueue.size(); in getTaskCount()
[all …]
|