Searched refs:numThreads (Results 1 - 21 of 21) sorted by relevance

/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/util/
H A DThreadPool.java86 * @param numThreads
97 public ThreadPool(String poolName, int numThreads, boolean daemon, argument
109 numThreads = Math.max(1, numThreads);
114 idleThreadList = new IPSThread[numThreads];
115 allThreadList = new IPSThread[numThreads];
120 for (int i = 0; i < numThreads; ++i) {
204 int numThreads = allThreadList.length;
206 while (i < numThreads) {
/forgerock/openam/openam-core/src/main/java/com/iplanet/services/util/
H A DThreadPool.java86 * @param numThreads
97 public ThreadPool(String poolName, int numThreads, boolean daemon, argument
109 numThreads = Math.max(1, numThreads);
114 idleThreadList = new IPSThread[numThreads];
115 allThreadList = new IPSThread[numThreads];
120 for (int i = 0; i < numThreads; ++i) {
204 int numThreads = allThreadList.length;
206 while (i < numThreads) {
/forgerock/opendj2/src/server/org/opends/server/core/
H A DServerShutdownMonitor.java85 int numThreads = threadGroup.enumerate(threadArray, true);
86 for (int i=0; i < numThreads; i++)
/forgerock/opendj2-hg/src/server/org/opends/server/core/
H A DServerShutdownMonitor.java85 int numThreads = threadGroup.enumerate(threadArray, true);
86 for (int i=0; i < numThreads; i++)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/core/
H A DServerShutdownMonitor.java85 int numThreads = threadGroup.enumerate(threadArray, true);
86 for (int i=0; i < numThreads; i++)
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/utils/blob/strategies/
H A DCompressionStrategyTest.java101 public Object[][] numThreads() { method in class:CompressionStrategyTest
117 * @param numThreads the number of threads to concurrently hammer the CompressionStrategy.
119 @Test(dataProvider = "numThreads", enabled = false)
120 public void testThroughPut(int numThreads) throws Exception { argument
122 final int roundsPerThread = TOTAL_ROUNDS / numThreads;
126 final Executor executor = Executors.newFixedThreadPool(numThreads);
129 final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1);
132 for (int i = 0; i < numThreads; ++i) {
150 // (String.format(Locale.US, "/Users/neilmadden/Desktop/CompressionStrategy-%03d.hgrm", numThreads))));
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/utils/blob/strategies/
H A DCompressionStrategyTest.java102 public Object[][] numThreads() { method in class:CompressionStrategyTest
118 * @param numThreads the number of threads to concurrently hammer the CompressionStrategy.
120 @Test(dataProvider = "numThreads", enabled = false)
121 public void testThroughPut(int numThreads) throws Exception { argument
123 final int roundsPerThread = TOTAL_ROUNDS / numThreads;
127 final Executor executor = Executors.newFixedThreadPool(numThreads);
130 final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1);
133 for (int i = 0; i < numThreads; ++i) {
151 // (String.format(Locale.US, "/Users/neilmadden/Desktop/CompressionStrategy-%03d.hgrm", numThreads))));
/forgerock/opendj-b2.6/src/server/org/opends/server/core/
H A DServerShutdownMonitor.java78 int numThreads = threadGroup.enumerate(threadArray, true);
79 for (int i=0; i < numThreads; i++)
/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DServerShutdownMonitor.java78 int numThreads = threadGroup.enumerate(threadArray, true);
79 for (int i=0; i < numThreads; i++)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/
H A DServerShutdownMonitor.java78 int numThreads = threadGroup.enumerate(threadArray, true);
79 for (int i=0; i < numThreads; i++)
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/
H A DDirectoryServerTestCase.java206 int numThreads = topGroup.enumerate(threads);
209 for (int i = 0; i < numThreads; i++)
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/
H A DDirectoryServerTestCase.java206 int numThreads = topGroup.enumerate(threads);
209 for (int i = 0; i < numThreads; i++)
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/
H A DDirectoryServerTestCase.java201 int numThreads = topGroup.enumerate(threads);
204 for (int i = 0; i < numThreads; i++)
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestListener.java823 int numThreads = topGroup.enumerate(threads);
826 for (int i = 0; i < numThreads; i++) {
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestListener.java823 int numThreads = topGroup.enumerate(threads);
826 for (int i = 0; i < numThreads; i++) {
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestListener.java823 int numThreads = topGroup.enumerate(threads);
826 for (int i = 0; i < numThreads; i++) {
/forgerock/opendj2/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj-b2.6/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj2.6.2/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj2-hg/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj-v3/opendj-server-legacy/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...

Completed in 61 milliseconds