Searched defs:numThreads (Results 1 - 9 of 9) 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-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/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/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/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 48 milliseconds