- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 217 for InterruptedException (0.22 sec)
-
guava/src/com/google/common/collect/ForwardingBlockingDeque.java
} @Override public void putFirst(E e) throws InterruptedException { delegate().putFirst(e); } @Override public void putLast(E e) throws InterruptedException { delegate().putLast(e); } @Override public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offerFirst(e, timeout, unit); } @Override
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
fail("expected to be interrupted"); } catch (InterruptedException expected) { } catch (TimeoutException e) { throw new RuntimeException(e); } // we were interrupted, but it's been cleared now assertFalse(Thread.interrupted()); assertFalse(sleeper.completed); try { assertTrue(delayedFuture.get()); } catch (InterruptedException e) { throw new RuntimeException(e); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java
} @Override public void putFirst(E e) throws InterruptedException { delegate().putFirst(e); } @Override public void putLast(E e) throws InterruptedException { delegate().putLast(e); } @Override public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offerFirst(e, timeout, unit); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
public static void awaitUninterruptibly(CountDownLatch latch) { boolean interrupted = false; try { while (true) { try { latch.await(); return; } catch (InterruptedException e) { interrupted = true; } } } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
@CheckReturnValue @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return delegate().awaitTermination(timeout, unit); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks) throws InterruptedException { return delegate().invokeAll(tasks); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
* be a SynchronousQueue. */ private ExecutorService threadPool; @Override public void setUp() { threadPool = newCachedThreadPool(); } @Override public void tearDown() throws InterruptedException { threadPool.shutdown(); assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); } private static <T> int drain( BlockingQueue<T> q,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
throws InterruptedException { lastMethodCalled = "invokeAll"; assertTaskWrapped(tasks); return inline.invokeAll(tasks); } @Override public <T> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException { assertTaskWrapped(tasks);
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java
} @Override public void putFirst(E e) throws InterruptedException { delegate().putFirst(e); } @Override public void putLast(E e) throws InterruptedException { delegate().putLast(e); } @Override public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offerFirst(e, timeout, unit); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
src/test/java/jcifs/tests/WatchTest.java
private void setupWatch ( SmbWatchHandle w ) throws InterruptedException { if ( this.future != null ) { this.future.cancel(true); } this.future = this.executor.submit(w); Thread.sleep(1000); } @Test public void testWatchCreate () throws CIFSException, MalformedURLException, UnknownHostException, InterruptedException, ExecutionException {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.4K bytes - Viewed (0) -
src/test/java/jcifs/tests/ConcurrencyTest.java
this.executor.shutdown(); this.executor.awaitTermination(10, TimeUnit.SECONDS); super.tearDown(); } @Test public void testExclusiveLock () throws InterruptedException, MalformedURLException, UnknownHostException { String fname = makeRandomName(); try ( SmbFile sr = getDefaultShareRoot(); SmbResource exclFile = new SmbFile(sr, fname) ) {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Nov 14 17:40:50 GMT 2021 - 17.6K bytes - Viewed (0)