/openjdk9/jdk/test/java/util/concurrent/FutureTask/ |
H A D | CancelledFutureLoops.java | 91 private final int nthreads; field in class:CancelledFutureLoops.FutureLoop 97 FutureLoop(int nthreads, SplittableRandom rnd) { argument 98 this.nthreads = nthreads; 100 barrier = new CyclicBarrier(nthreads+1, timer); 105 Future[] futures = new Future[nthreads]; 106 for (int i = 0; i < nthreads; ++i) 112 for (int i = 1; i < nthreads; ++i) { 122 for (int i = 1; i < nthreads; ++i) {
|
/openjdk9/jdk/test/java/util/concurrent/atomic/ |
H A D | DoubleAdderDemo.java | 84 static void syncTest(int nthreads, int incs) { argument 86 Phaser phaser = new Phaser(nthreads + 1); 88 for (int i = 0; i < nthreads; ++i) 90 report(nthreads, incs, timeTasks(phaser), a.sum()); 93 static void adderTest(int nthreads, int incs) { argument 95 Phaser phaser = new Phaser(nthreads + 1); 97 for (int i = 0; i < nthreads; ++i) 99 report(nthreads, incs, timeTasks(phaser), a.sum()); 102 static void report(int nthreads, int incs, long time, double sum) { argument 103 long total = (long)nthreads * inc [all...] |
H A D | LongAdderDemo.java | 78 static void casTest(int nthreads, int incs) { argument 80 Phaser phaser = new Phaser(nthreads + 1); 82 for (int i = 0; i < nthreads; ++i) 84 report(nthreads, incs, timeTasks(phaser), a.get()); 87 static void adderTest(int nthreads, int incs) { argument 89 Phaser phaser = new Phaser(nthreads + 1); 91 for (int i = 0; i < nthreads; ++i) 93 report(nthreads, incs, timeTasks(phaser), a.sum()); 96 static void report(int nthreads, int incs, long time, long sum) { argument 97 long total = (long)nthreads * inc [all...] |
/openjdk9/jdk/test/java/util/concurrent/locks/ReentrantLock/ |
H A D | CancelledLockLoops.java | 68 private final int nthreads; field in class:CancelledLockLoops.Loops 70 Loops(int nthreads) { argument 71 this.nthreads = nthreads; 72 if (print) System.out.print("Threads: " + nthreads); 73 barrier = new CyclicBarrier(nthreads+1, timer); 78 Thread[] threads = new Thread[nthreads];
|
H A D | SimpleReentrantLockLoops.java | 83 private final int nthreads; field in class:SimpleReentrantLockLoops.ReentrantLockLoop 84 ReentrantLockLoop(int nthreads) { argument 85 this.nthreads = nthreads; 86 barrier = new CyclicBarrier(nthreads+1, timer); 90 for (int i = 0; i < nthreads; ++i) 96 long tpi = time / ((long)iters * nthreads);
|
H A D | TimeoutLockLoops.java | 79 private final int nthreads; field in class:TimeoutLockLoops.ReentrantLockLoop 81 ReentrantLockLoop(int nthreads) { argument 82 this.nthreads = nthreads; 83 barrier = new CyclicBarrier(nthreads+1, timer); 87 for (int i = 0; i < nthreads; ++i) {
|
H A D | LockOncePerThreadLoops.java | 55 static int nthreads = 20; field in class:LockOncePerThreadLoops 85 barrier = new CyclicBarrier(nthreads+1, timer); 91 for (int i = 0; i < nthreads; ++i)
|
/openjdk9/jdk/test/com/sun/jdi/ |
H A D | MultiBreakpointsTest.java | 43 * The current max allowed value of nthreads is 30. 70 int nthreads; 72 String nStr = System.getProperty("nthreads"); 75 throw new RuntimeException("nthreads = null in debuggee"); 77 nthreads = Integer.parseInt(nStr); 85 System.out.println("Debuggee: nthreads = " + nthreads + ", nhits = " + nhits); 87 MultiBreakpointsTarg ptr = new MultiBreakpointsTarg(nthreads, nhits); 89 // for (int i = 0; i < nthreads; i++) { 204 static int nthreads; field in class:MultiBreakpointsTest [all...] |
/openjdk9/jdk/test/java/util/concurrent/Exchanger/ |
H A D | ExchangeLoops.java | 126 static void oneRun(int nthreads, int iters) throws Exception { argument 128 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1, timer); 131 for (int i = 0; i < nthreads; ++i) { 134 r = (i+2 < nthreads) ? new Exchanger<Int>() : null; 140 System.out.println(LoopHelpers.rightJustify(time / (iters * nthreads + iters * (nthreads-2))) + " ns per transfer");
|
/openjdk9/jdk/test/java/util/concurrent/locks/Lock/ |
H A D | CheckedLockLoops.java | 73 static void oneTest(int nthreads, int iters) throws Exception { argument 74 System.out.println("Threads: " + nthreads); 77 new BuiltinLockLoop().test(v, nthreads, iters); 80 new ReentrantLockLoop().test(v, nthreads, iters); 83 new MutexLoop().test(v, nthreads, iters); 86 new ReentrantWriteLockLoop().test(v, nthreads, iters); 89 new ReentrantReadWriteLockLoop().test(v, nthreads, iters); 92 new SemaphoreLoop().test(v, nthreads, iters); 95 new FairSemaphoreLoop().test(v, nthreads, iters); 98 new FairReentrantLockLoop().test(v, nthreads, iter 128 test(int initialValue, int nthreads, int iters) argument [all...] |
/openjdk9/jdk/src/java.base/share/classes/java/lang/ |
H A D | ThreadGroup.java | 65 int nthreads; field in class:ThreadGroup 344 result = nthreads; 430 int nt = nthreads; 636 for (int i = 0 ; i < nthreads ; i++) { 692 for (int i = 0 ; i < nthreads ; i++) { 740 for (int i = 0 ; i < nthreads ; i++) { 775 if (destroyed || (nthreads > 0)) { 788 nthreads = 0; 843 if (nthreads == 0) { 846 if (daemon && (nthreads [all...] |
/openjdk9/jdk/test/java/util/concurrent/tck/ |
H A D | DoubleAdderTest.java | 160 final int nthreads = 4; 163 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); 164 for (int i = 0; i < nthreads; ++i) 168 double total = (long)nthreads * incs;
|
H A D | LongAdderTest.java | 183 final int nthreads = 4; 186 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); 187 for (int i = 0; i < nthreads; ++i) 191 long total = (long)nthreads * incs;
|
H A D | DoubleAccumulatorTest.java | 148 final int nthreads = 4; 151 Phaser phaser = new Phaser(nthreads + 1); 152 for (int i = 0; i < nthreads; ++i)
|
H A D | LongAccumulatorTest.java | 148 final int nthreads = 4; 151 Phaser phaser = new Phaser(nthreads + 1); 152 for (int i = 0; i < nthreads; ++i)
|
/openjdk9/hotspot/src/share/vm/prims/ |
H A D | jvmtiEnv.cpp | 875 int nthreads = 0; local 882 nthreads = tle.num_threads(); 883 *threads_count_ptr = nthreads; 885 if (nthreads == 0) { 890 thread_objs = NEW_RESOURCE_ARRAY(Handle, nthreads); 893 for (int i=0; i < nthreads; i++) { 898 jthread *jthreads = new_jthreadArray(nthreads, thread_objs); 1396 int nthreads = 0; local 1407 nthreads = java_lang_ThreadGroup::nthreads(group_hd [all...] |
/openjdk9/hotspot/src/share/vm/classfile/ |
H A D | javaClasses.hpp | 419 static int nthreads(oop java_thread_group);
|
H A D | javaClasses.cpp | 1434 int java_lang_ThreadGroup::nthreads(oop java_thread_group) { function in class:java_lang_ThreadGroup
|