/openjdk9/jdk/test/java/lang/ThreadLocal/ |
H A D | Basic.java | 39 int threadCount = 100; 40 Thread th[] = new Thread[threadCount]; 41 final int x[] = new int[threadCount]; 44 for(int i=0; i<threadCount; i++) { 58 for(int i=0; i<threadCount; i++) 62 for(int i=0; i<threadCount; i++)
|
H A D | TLRemoveTest.java | 41 int threadCount = 100; 47 Thread th[] = new Thread[threadCount]; 48 final int x[] = new int[threadCount]; 49 final Throwable exceptions[] = new Throwable[threadCount]; 51 for(int i = 0; i<threadCount; i++) { 88 for(int i = 0; i<threadCount; i++) 92 for(int i = 0; i<threadCount; i++){
|
H A D | ThreadLocalSupplierTest.java | 86 final int threadCount = 500; 87 final Thread th[] = new Thread[threadCount]; 88 final boolean visited[] = new boolean[threadCount]; 91 for (int i = 0; i < threadCount; i++) { 107 for (int i = 0; i < threadCount; i++) { 111 assertEquals(theSupply.numCalls(), threadCount); 115 for (int i = 0; i < threadCount; i++) {
|
/openjdk9/jdk/test/java/lang/InheritableThreadLocal/ |
H A D | Basic.java | 41 static int threadCount = 100; field in class:Basic 45 x = new int[threadCount]; 53 for(int i=0; i<threadCount; i++) 61 if (((Integer)(n.get())).intValue() < threadCount-1) {
|
H A D | ITLRemoveTest.java | 44 static int threadCount = 100; field in class:ITLRemoveTest 53 x = new int[threadCount]; 54 exceptions = new Throwable[threadCount]; 62 for(int i = 0; i<threadCount; i++){ 93 if (threadId < (threadCount-1+INITIAL_VALUE)) {
|
/openjdk9/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
H A D | Custom.java | 65 super(threadCount, threadCount, 67 new ArrayBlockingQueue<Runnable>(2*threadCount)); 80 super(threadCount); 104 private static final int threadCount = 10; field in class:Custom 124 equal(tpe.getCorePoolSize(), threadCount); 126 for (int i = 0; i < threadCount; i++) 128 equal(countExecutorThreads(), threadCount); 129 equal(CustomTask.births.get(), threadCount); 135 for (int i = 0; i < threadCount; [all...] |
H A D | CoreThreadTimeOut.java | 73 final int threadCount = 10; 75 BlockingQueue<Runnable> q = new ArrayBlockingQueue<>(2*threadCount); 77 = new ThreadPoolExecutor(threadCount, threadCount, 80 equal(tpe.getCorePoolSize(), threadCount); 86 for (int i = 0; i < threadCount; i++) {
|
/openjdk9/jdk/test/java/util/concurrent/SynchronousQueue/ |
H A D | Fairness.java | 42 final int threadCount = 10; 45 for (int i = 0; i < threadCount; i++) { 60 for (int i = 0; i < threadCount; i++) { 63 if (fair ? j != i : j != threadCount - 1 - i)
|
/openjdk9/jdk/src/jdk.jdwp.agent/share/native/libjdwp/ |
H A D | ThreadGroupReferenceImpl.c | 103 jint threadCount; local 109 &threadCount,&theThreads, 118 threadCount = filterDebugThreads(theThreads, threadCount); 120 (void)outStream_writeInt(out, threadCount); 121 for (i = 0; i < threadCount; i++) {
|
H A D | VirtualMachineImpl.c | 537 jint threadCount; local 540 theThreads = allThreads(&threadCount); 545 threadCount = filterDebugThreads(theThreads, threadCount); 547 (void)outStream_writeInt(out, threadCount); 548 for (i = 0; i <threadCount; i++) {
|
H A D | threadControl.c | 813 jint threadCount; local 816 threads = allThreads(&threadCount); 823 for (i = 0; i < threadCount; i++) {
|
/openjdk9/jdk/test/java/lang/management/ThreadMXBean/ |
H A D | ThreadLists.java | 56 int threadCount = threadBean.getThreadCount(); 61 System.out.println("ThreadMXBean: " + threadCount + " live threads(s)"); 67 if (activeCount != threadCount) failed = true;
|
/openjdk9/jdk/test/java/io/BufferedReader/ |
H A D | ReadLineSync.java | 50 int threadCount = 2; 52 ExecutorService es = Executors.newFixedThreadPool(threadCount); 54 for (int i=0; i < threadCount; i++)
|
/openjdk9/jdk/test/java/util/concurrent/tck/ |
H A D | ThreadLocalTest.java | 119 final int threadCount = 10; 120 final int[] x = new int[threadCount]; 124 for (int i = 0; i < threadCount; i++) {
|
/openjdk9/jdk/test/java/util/Random/ |
H A D | DistinctSeeds.java | 62 final int threadCount = 2; 65 for (int i = 0; i < threadCount; i++) {
|
/openjdk9/jdk/test/java/security/SecureRandom/ |
H A D | MultiThreadTest.java | 103 int threadCount = (int) pow(2, 8 * byteLen); 105 + "random numbers concurrently.", threadCount); 129 for (int i = 0; i < threadCount; i++) { 134 for (int i = 0; i < threadCount; i++) { 142 mech, threadCount, reSeed);
|
/openjdk9/jdk/src/java.base/share/classes/sun/nio/ch/ |
H A D | AsynchronousChannelGroupImpl.java | 58 private final AtomicInteger threadCount = new AtomicInteger(); field in class:AsynchronousChannelGroupImpl 133 threadCount.incrementAndGet(); 141 threadCount.incrementAndGet(); 149 final int threadCount() { method in class:AsynchronousChannelGroupImpl 150 return threadCount.get(); 166 return threadCount.get(); 171 return threadCount.decrementAndGet();
|
/openjdk9/jdk/src/java.base/solaris/classes/sun/nio/ch/ |
H A D | SolarisEventPort.java | 120 int nThreads = threadCount();
|
/openjdk9/jdk/src/java.base/linux/classes/sun/nio/ch/ |
H A D | EPollPort.java | 159 int nThreads = threadCount();
|
/openjdk9/jdk/src/java.base/macosx/classes/sun/nio/ch/ |
H A D | KQueuePort.java | 157 int nThreads = threadCount();
|
/openjdk9/hotspot/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.hotspot/src/org/graalvm/compiler/hotspot/ |
H A D | CompileTheWorld.java | 543 int threadCount = 1; 545 threadCount = CompileTheWorldOptions.CompileTheWorldThreads.getValue(); 546 if (threadCount == 0) { 547 threadCount = Runtime.getRuntime().availableProcessors(); 552 threadPool = new ThreadPoolExecutor(threadCount, threadCount, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), factory);
|
/openjdk9/jdk/src/java.base/windows/classes/sun/nio/ch/ |
H A D | Iocp.java | 195 int nThreads = threadCount();
|
/openjdk9/jdk/test/java/util/concurrent/ConcurrentQueues/ |
H A D | RemovePollRace.java | 132 final int threadCount = adderCount + removerCount + pollerCount;
|
/openjdk9/jdk/src/java.base/aix/classes/sun/nio/ch/ |
H A D | AixPollPort.java | 229 int nThreads = threadCount();
|