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

/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java111 private int numWorkerThreads; field in class:ParallelWorkQueue
149 numWorkerThreads =
157 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
158 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
348 if (currentThreads > numWorkerThreads)
355 if (currentThreads <= numWorkerThreads)
409 if (currentThreads > numWorkerThreads)
416 if (currentThreads <= numWorkerThreads)
556 numWorkerThreads = newNumThreads;
604 return this.numWorkerThreads;
[all...]
H A DTraditionalWorkQueue.java120 private int numWorkerThreads; field in class:TraditionalWorkQueue
185 numWorkerThreads =
203 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
588 if (currentThreads > numWorkerThreads)
595 if (currentThreads <= numWorkerThreads)
724 numWorkerThreads = newNumThreads;
853 return this.numWorkerThreads;
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java110 private int numWorkerThreads; field in class:ParallelWorkQueue
148 numWorkerThreads =
156 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
157 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
347 if (currentThreads > numWorkerThreads)
354 if (currentThreads <= numWorkerThreads)
408 if (currentThreads > numWorkerThreads)
415 if (currentThreads <= numWorkerThreads)
555 numWorkerThreads = newNumThreads;
603 return this.numWorkerThreads;
[all...]
H A DTraditionalWorkQueue.java119 private int numWorkerThreads; field in class:TraditionalWorkQueue
184 numWorkerThreads =
202 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
587 if (currentThreads > numWorkerThreads)
594 if (currentThreads <= numWorkerThreads)
723 numWorkerThreads = newNumThreads;
852 return this.numWorkerThreads;
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java111 private int numWorkerThreads; field in class:ParallelWorkQueue
149 numWorkerThreads =
157 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
158 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
348 if (currentThreads > numWorkerThreads)
355 if (currentThreads <= numWorkerThreads)
409 if (currentThreads > numWorkerThreads)
416 if (currentThreads <= numWorkerThreads)
556 numWorkerThreads = newNumThreads;
604 return this.numWorkerThreads;
[all...]
H A DTraditionalWorkQueue.java120 private int numWorkerThreads; field in class:TraditionalWorkQueue
185 numWorkerThreads =
203 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
588 if (currentThreads > numWorkerThreads)
595 if (currentThreads <= numWorkerThreads)
724 numWorkerThreads = newNumThreads;
853 return this.numWorkerThreads;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java111 private int numWorkerThreads; field in class:ParallelWorkQueue
149 numWorkerThreads =
157 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
158 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
348 if (currentThreads > numWorkerThreads)
355 if (currentThreads <= numWorkerThreads)
409 if (currentThreads > numWorkerThreads)
416 if (currentThreads <= numWorkerThreads)
556 numWorkerThreads = newNumThreads;
604 return this.numWorkerThreads;
[all...]
H A DTraditionalWorkQueue.java120 private int numWorkerThreads; field in class:TraditionalWorkQueue
185 numWorkerThreads =
203 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
588 if (currentThreads > numWorkerThreads)
595 if (currentThreads <= numWorkerThreads)
724 numWorkerThreads = newNumThreads;
853 return this.numWorkerThreads;
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DParallelWorkQueue.java110 private int numWorkerThreads; field in class:ParallelWorkQueue
148 numWorkerThreads =
156 workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
157 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
347 if (currentThreads > numWorkerThreads)
354 if (currentThreads <= numWorkerThreads)
408 if (currentThreads > numWorkerThreads)
415 if (currentThreads <= numWorkerThreads)
555 numWorkerThreads = newNumThreads;
603 return this.numWorkerThreads;
[all...]
H A DTraditionalWorkQueue.java119 private int numWorkerThreads; field in class:TraditionalWorkQueue
184 numWorkerThreads =
202 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
587 if (currentThreads > numWorkerThreads)
594 if (currentThreads <= numWorkerThreads)
723 numWorkerThreads = newNumThreads;
852 return this.numWorkerThreads;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DParallelWorkQueue.java100 private int numWorkerThreads; field in class:ParallelWorkQueue
136 numWorkerThreads =
143 workerThreads = new ArrayList<>(numWorkerThreads);
144 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
316 if (currentThreads > numWorkerThreads)
323 if (currentThreads <= numWorkerThreads)
373 if (currentThreads > numWorkerThreads)
380 if (currentThreads <= numWorkerThreads)
508 numWorkerThreads = newNumThreads;
551 return this.numWorkerThreads;
[all...]
H A DTraditionalWorkQueue.java109 private int numWorkerThreads; field in class:TraditionalWorkQueue
172 numWorkerThreads =
190 for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
550 if (currentThreads > numWorkerThreads)
557 if (currentThreads <= numWorkerThreads)
681 numWorkerThreads = newNumThreads;
804 return this.numWorkerThreads;

Completed in 45 milliseconds