Searched refs:threadCount (Results 1 - 24 of 24) sorted by relevance

/openjdk9/jdk/test/java/lang/ThreadLocal/
H A DBasic.java39 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 DTLRemoveTest.java41 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 DThreadLocalSupplierTest.java86 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 DBasic.java41 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 DITLRemoveTest.java44 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 DCustom.java65 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 DCoreThreadTimeOut.java73 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 DFairness.java42 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 DThreadGroupReferenceImpl.c103 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 DVirtualMachineImpl.c537 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 DthreadControl.c813 jint threadCount; local
816 threads = allThreads(&threadCount);
823 for (i = 0; i < threadCount; i++) {
/openjdk9/jdk/test/java/lang/management/ThreadMXBean/
H A DThreadLists.java56 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 DReadLineSync.java50 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 DThreadLocalTest.java119 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 DDistinctSeeds.java62 final int threadCount = 2;
65 for (int i = 0; i < threadCount; i++) {
/openjdk9/jdk/test/java/security/SecureRandom/
H A DMultiThreadTest.java103 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 DAsynchronousChannelGroupImpl.java58 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 DSolarisEventPort.java120 int nThreads = threadCount();
/openjdk9/jdk/src/java.base/linux/classes/sun/nio/ch/
H A DEPollPort.java159 int nThreads = threadCount();
/openjdk9/jdk/src/java.base/macosx/classes/sun/nio/ch/
H A DKQueuePort.java157 int nThreads = threadCount();
/openjdk9/hotspot/src/jdk.internal.vm.compiler/share/classes/org.graalvm.compiler.hotspot/src/org/graalvm/compiler/hotspot/
H A DCompileTheWorld.java543 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 DIocp.java195 int nThreads = threadCount();
/openjdk9/jdk/test/java/util/concurrent/ConcurrentQueues/
H A DRemovePollRace.java132 final int threadCount = adderCount + removerCount + pollerCount;
/openjdk9/jdk/src/java.base/aix/classes/sun/nio/ch/
H A DAixPollPort.java229 int nThreads = threadCount();

Completed in 298 milliseconds