- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 150 for Kuwait (0.2 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #1 barrier.await(1, TimeUnit.SECONDS); // WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException { startLatch.await(); } public void stop() { stopLatch.countDown(); } public boolean isRunning() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } public void waitForStart() throws InterruptedException { startLatch.await(); } public void stop() { stopLatch.countDown(); } public boolean isRunning() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
executor.execute(wrapper); } barrier.await(); // release the threads! barrier.await(); // wait for them all to complete assertEquals(1, task.get().intValue()); assertEquals(1, counter.get()); } executor.shutdown(); } @J2ktIncompatible @GwtIncompatible // blocking wait public void testToString() throws Exception {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java
abstract class ForwardingCondition implements Condition { abstract Condition delegate(); @Override public void await() throws InterruptedException { delegate().await(); } @Override public boolean await(long time, TimeUnit unit) throws InterruptedException { return delegate().await(time, unit); } @Override public void awaitUninterruptibly() { delegate().awaitUninterruptibly(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
*/ public void assertSuccess(Object expectedData) throws Throwable { // Verify that the listener executed in a reasonable amount of time. Assert.assertTrue(countDownLatch.await(1L, SECONDS)); try { Assert.assertEquals(expectedData, future.get()); } catch (ExecutionException e) { throw e.getCause(); } } /**
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
assertEquals(3L, countDownLatch.getCount()); list.execute(); // Verify that all of the runnables execute in a reasonable amount of time. assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); } public void testExecute_idempotent() { final AtomicInteger runCalled = new AtomicInteger(); list.add( new Runnable() { @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
}) .start(); future.cancel(true); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertTrue(successLatch.await(200, MILLISECONDS)); assertTrue(listenerLatch.await(200, MILLISECONDS)); latch.countDown(); exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
private void assertInterruptibleDrained(BlockingQueue<Object> q) { // nothing to drain, thus this should wait doing nothing try { assertEquals(0, Queues.drain(q, ImmutableList.of(), 0, 10, MILLISECONDS)); } catch (InterruptedException e) { throw new AssertionError(); } // but does the wait actually occurs? @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0)