Searched refs:nthreads (Results 1 - 18 of 18) sorted by relevance

/openjdk9/jdk/test/java/util/concurrent/FutureTask/
H A DCancelledFutureLoops.java91 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 DDoubleAdderDemo.java84 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 DLongAdderDemo.java78 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 DCancelledLockLoops.java68 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 DSimpleReentrantLockLoops.java83 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 DTimeoutLockLoops.java79 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 DLockOncePerThreadLoops.java55 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 DMultiBreakpointsTest.java43 * 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 DExchangeLoops.java126 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 DCheckedLockLoops.java73 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 DThreadGroup.java65 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 DDoubleAdderTest.java160 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 DLongAdderTest.java183 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 DDoubleAccumulatorTest.java148 final int nthreads = 4;
151 Phaser phaser = new Phaser(nthreads + 1);
152 for (int i = 0; i < nthreads; ++i)
H A DLongAccumulatorTest.java148 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 DjvmtiEnv.cpp875 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 DjavaClasses.hpp419 static int nthreads(oop java_thread_group);
H A DjavaClasses.cpp1434 int java_lang_ThreadGroup::nthreads(oop java_thread_group) { function in class:java_lang_ThreadGroup

Completed in 500 milliseconds