/openjdk7/jdk/test/java/nio/channels/AsynchronousChannelGroup/ |
H A D | Attack.java | 33 private final CountDownLatch latch = new CountDownLatch(1); field in class:Attack 52 latch.countDown(); 57 latch.await();
|
H A D | AsExecutor.java | 63 final CountDownLatch latch = new CountDownLatch(1); 66 latch.countDown(); 69 latch.await();
|
H A D | Restart.java | 95 final CountDownLatch latch = new CountDownLatch(1); 103 latch.countDown(); 125 latch.await();
|
H A D | GroupOfOne.java | 90 // the latch counts down when: 93 final CountDownLatch latch = new CountDownLatch(2); 109 latch.countDown(); 125 latch.countDown(); 135 latch.await();
|
/openjdk7/jdk/test/java/lang/Runtime/exec/ |
H A D | StreamsSurviveDestroy.java | 44 CountDownLatch latch; field in class:StreamsSurviveDestroy.Copier 54 this.latch = l; 65 latch.countDown(); 102 CountDownLatch latch = new CountDownLatch(2); 107 false, false, latch); 109 false, false, latch); 110 latch.await(); // Wait till both Copiers about to read 122 CountDownLatch latch = new CountDownLatch(2); 127 true, false, latch); 129 true, false, latch); [all...] |
/openjdk7/jdk/test/java/util/concurrent/CountDownLatch/ |
H A D | Basic.java | 53 private Awaiter awaiter(final CountDownLatch latch, argument 56 System.out.println("without millis: " + latch.toString()); 60 latch.await(); 66 private Awaiter awaiter(final CountDownLatch latch, argument 70 System.out.println("with millis: "+latch.toString()); 74 latch.await(millis, TimeUnit.MILLISECONDS); 80 private AwaiterFactory awaiterFactories(final CountDownLatch latch, argument 85 return awaiter(latch, gate); }}; 88 return awaiter(latch, gate, 10000); }}; 97 CountDownLatch latch [all...] |
/openjdk7/jdk/test/sun/java2d/DirectX/ |
H A D | DrawBitmaskToSurfaceTest.java | 43 private static java.util.concurrent.CountDownLatch latch = null; field in class:DrawBitmaskToSurfaceTest 71 if (latch != null) { 72 latch.countDown(); 85 latch = new CountDownLatch(1); 90 if (latch.getCount() > 0) { 91 latch.await();
|
/openjdk7/jdk/test/sun/java2d/DirectX/InfiniteValidationLoopTest/ |
H A D | InfiniteValidationLoopTest.java | 44 private static volatile CountDownLatch latch; field in class:InfiniteValidationLoopTest 56 latch.countDown(); 94 latch = new CountDownLatch(1); 99 try { latch.await(); } catch (InterruptedException ex) {} 102 latch = new CountDownLatch(1); 107 try { latch.await(); } catch (InterruptedException ex) {}
|
/openjdk7/jdk/test/com/sun/jdi/ |
H A D | NativeInstanceFilterTarg.java | 32 latch(s1); 43 public static String latch(String s) { return s; } method in class:NativeInstanceFilterTarg
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | PendingFuture.java | 50 // latch for waiting (created lazily if needed) 51 private CountDownLatch latch; field in class:PendingFuture 117 // creates latch if required; return true if caller needs to wait 123 if (latch == null) 124 latch = new CountDownLatch(1); 141 if (latch != null) 142 latch.countDown(); 159 if (latch != null) 160 latch.countDown(); 180 latch [all...] |
/openjdk7/jdk/test/java/nio/channels/AsynchronousFileChannel/ |
H A D | LotsOfWrites.java | 41 * counting down a latch to release waiters when done. 46 private final CountDownLatch latch; field in class:LotsOfWrites.Writer 72 latch.countDown(); 75 Writer(File file, long size, CountDownLatch latch) throws IOException { argument 78 this.latch = latch; 122 CountDownLatch latch = new CountDownLatch(count); 129 Writer writer = new Writer(blah, size, latch); 135 latch.await();
|
H A D | Basic.java | 221 final CountDownLatch latch = new CountDownLatch(1); 228 latch.countDown(); 238 await(latch); 313 final CountDownLatch latch = new CountDownLatch(1); 318 latch.countDown(); 323 await(latch); 354 final CountDownLatch latch = new CountDownLatch(1); 357 latch.countDown(); 362 await(latch); 553 final CountDownLatch latch 599 await(CountDownLatch latch) argument [all...] |
/openjdk7/jdk/test/java/rmi/transport/acceptLoop/ |
H A D | CloseServerSocketOnTermination.java | 72 CountDownLatch latch = new CountDownLatch(1); 73 UnicastRemoteObject.exportObject(impl, 0, null, new SSF(t, latch)); 74 if (!latch.await(TIMEOUT, TimeUnit.MILLISECONDS)) {
|
/openjdk7/jdk/test/java/awt/EventQueue/6638195/ |
H A D | bug6638195.java | 66 final CountDownLatch latch = new CountDownLatch(1); 70 latch.countDown(); 73 latch.await();
|
/openjdk7/jdk/test/java/util/concurrent/ScheduledThreadPoolExecutor/ |
H A D | DecorateTask.java | 34 Runnable countDownTask(final CountDownLatch latch) { argument 36 latch.countDown(); 37 if (latch.getCount() <= 0)
|
/openjdk7/jdk/test/sun/java2d/DirectX/RenderingToCachedGraphicsTest/ |
H A D | RenderingToCachedGraphicsTest.java | 53 private static volatile CountDownLatch latch; field in class:RenderingToCachedGraphicsTest 75 latch.countDown(); 159 latch = new CountDownLatch(1); 165 try { latch.await(); } catch (InterruptedException ex) {}
|
/openjdk7/jdk/test/com/sun/net/httpserver/bugs/6725892/ |
H A D | Test.java | 153 CountDownLatch latch; field in class:Test.Worker 162 Worker (CountDownLatch latch, Mode mode) { argument 163 this.latch = latch; 182 latch.countDown(); 218 latch.countDown();
|
/openjdk7/jdk/src/share/classes/sun/security/provider/ |
H A D | SeedGenerator.java | 319 int latch = 0; 320 latch = 0; 324 latch++; 329 v ^= rndTab[latch % 255]; 330 counter += latch;
|
/openjdk7/jdk/test/java/util/Timer/ |
H A D | Args.java | 52 TimerTask counter(final CountDownLatch latch) { argument 54 check(latch.getCount() > 0); 55 latch.countDown();
|
/openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/ |
H A D | RemovePollRace.java | 113 void await(CountDownLatch latch) { argument 114 try { latch.await(); }
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
H A D | Basic.java | 418 final CountDownLatch latch = new CountDownLatch(1); 425 latch.countDown(); 432 latch.await(); 467 final CountDownLatch latch = new CountDownLatch(1); 473 latch.countDown(); 494 latch.await();
|
/openjdk7/jdk/test/java/lang/ProcessBuilder/ |
H A D | Basic.java | 1912 final CountDownLatch latch = new CountDownLatch(1); 1923 latch.countDown(); 1933 latch.await();
|