Searched defs:workerThreads (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java87 private ArrayList<ParallelWorkerThread> workerThreads; field in class:ParallelWorkQueue
157 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
164 workerThreads.add(t);
230 for (ParallelWorkerThread t : workerThreads)
347 int currentThreads = workerThreads.size();
350 if (workerThreads.remove(Thread.currentThread()))
408 int currentThreads = workerThreads.size();
411 if (workerThreads.remove(Thread.currentThread()))
531 int currentThreads = workerThreads.size();
545 workerThreads
[all...]
H A DTraditionalWorkQueue.java83 private final ArrayList<TraditionalWorkerThread> workerThreads = field in class:TraditionalWorkQueue
209 workerThreads.add(t);
288 for (TraditionalWorkerThread t : workerThreads)
587 int currentThreads = workerThreads.size();
590 if (workerThreads.remove(Thread.currentThread()))
700 int currentThreads = workerThreads.size();
713 workerThreads.add(t);
829 for (TraditionalWorkerThread t : workerThreads)
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java86 private ArrayList<ParallelWorkerThread> workerThreads; field in class:ParallelWorkQueue
156 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
163 workerThreads.add(t);
229 for (ParallelWorkerThread t : workerThreads)
346 int currentThreads = workerThreads.size();
349 if (workerThreads.remove(Thread.currentThread()))
407 int currentThreads = workerThreads.size();
410 if (workerThreads.remove(Thread.currentThread()))
530 int currentThreads = workerThreads.size();
544 workerThreads
[all...]
H A DTraditionalWorkQueue.java82 private final ArrayList<TraditionalWorkerThread> workerThreads = field in class:TraditionalWorkQueue
208 workerThreads.add(t);
287 for (TraditionalWorkerThread t : workerThreads)
586 int currentThreads = workerThreads.size();
589 if (workerThreads.remove(Thread.currentThread()))
699 int currentThreads = workerThreads.size();
712 workerThreads.add(t);
828 for (TraditionalWorkerThread t : workerThreads)
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java87 private ArrayList<ParallelWorkerThread> workerThreads; field in class:ParallelWorkQueue
157 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
164 workerThreads.add(t);
230 for (ParallelWorkerThread t : workerThreads)
347 int currentThreads = workerThreads.size();
350 if (workerThreads.remove(Thread.currentThread()))
408 int currentThreads = workerThreads.size();
411 if (workerThreads.remove(Thread.currentThread()))
531 int currentThreads = workerThreads.size();
545 workerThreads
[all...]
H A DTraditionalWorkQueue.java83 private final ArrayList<TraditionalWorkerThread> workerThreads = field in class:TraditionalWorkQueue
209 workerThreads.add(t);
288 for (TraditionalWorkerThread t : workerThreads)
587 int currentThreads = workerThreads.size();
590 if (workerThreads.remove(Thread.currentThread()))
700 int currentThreads = workerThreads.size();
713 workerThreads.add(t);
829 for (TraditionalWorkerThread t : workerThreads)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java87 private ArrayList<ParallelWorkerThread> workerThreads; field in class:ParallelWorkQueue
157 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
164 workerThreads.add(t);
230 for (ParallelWorkerThread t : workerThreads)
347 int currentThreads = workerThreads.size();
350 if (workerThreads.remove(Thread.currentThread()))
408 int currentThreads = workerThreads.size();
411 if (workerThreads.remove(Thread.currentThread()))
531 int currentThreads = workerThreads.size();
545 workerThreads
[all...]
H A DTraditionalWorkQueue.java83 private final ArrayList<TraditionalWorkerThread> workerThreads = field in class:TraditionalWorkQueue
209 workerThreads.add(t);
288 for (TraditionalWorkerThread t : workerThreads)
587 int currentThreads = workerThreads.size();
590 if (workerThreads.remove(Thread.currentThread()))
700 int currentThreads = workerThreads.size();
713 workerThreads.add(t);
829 for (TraditionalWorkerThread t : workerThreads)
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java86 private ArrayList<ParallelWorkerThread> workerThreads; field in class:ParallelWorkQueue
156 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
163 workerThreads.add(t);
229 for (ParallelWorkerThread t : workerThreads)
346 int currentThreads = workerThreads.size();
349 if (workerThreads.remove(Thread.currentThread()))
407 int currentThreads = workerThreads.size();
410 if (workerThreads.remove(Thread.currentThread()))
530 int currentThreads = workerThreads.size();
544 workerThreads
[all...]
H A DTraditionalWorkQueue.java82 private final ArrayList<TraditionalWorkerThread> workerThreads = field in class:TraditionalWorkQueue
208 workerThreads.add(t);
287 for (TraditionalWorkerThread t : workerThreads)
586 int currentThreads = workerThreads.size();
589 if (workerThreads.remove(Thread.currentThread()))
699 int currentThreads = workerThreads.size();
712 workerThreads.add(t);
828 for (TraditionalWorkerThread t : workerThreads)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DParallelWorkQueue.java76 private ArrayList<ParallelWorkerThread> workerThreads; field in class:ParallelWorkQueue
143 workerThreads = new ArrayList<>(numWorkerThreads);
150 workerThreads.add(t);
203 for (ParallelWorkerThread t : workerThreads)
315 int currentThreads = workerThreads.size();
318 if (workerThreads.remove(Thread.currentThread()))
372 int currentThreads = workerThreads.size();
375 if (workerThreads.remove(Thread.currentThread()))
483 int currentThreads = workerThreads.size();
497 workerThreads
[all...]
H A DTraditionalWorkQueue.java76 private final ArrayList<TraditionalWorkerThread> workerThreads = new ArrayList<>(); field in class:TraditionalWorkQueue
196 workerThreads.add(t);
261 for (TraditionalWorkerThread t : workerThreads)
549 int currentThreads = workerThreads.size();
552 if (workerThreads.remove(Thread.currentThread()))
657 int currentThreads = workerThreads.size();
670 workerThreads.add(t);
780 for (TraditionalWorkerThread t : workerThreads)

Completed in 43 milliseconds