- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 187 for InterruptedException (0.09 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/org/codelibs/fess/util/InputStreamThreadTest.java
assertEquals("InputStreamThread", thread.getName()); assertNotNull(thread); } @Test public void test_run_withBuffering() throws InterruptedException { String input = "line1\nline2\nline3"; InputStream is = new ByteArrayInputStream(input.getBytes(StandardCharsets.UTF_8));Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 12K bytes - Click Count (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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (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); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* * @throws InterruptedException if interrupted while waiting */ public void enterInterruptibly() throws InterruptedException { lock.lockInterruptibly(); } /** * Enters this monitor. Blocks at most the given time, and may be interrupted. * * @return whether the monitor was entered * @throws InterruptedException if interrupted while waiting
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.3K bytes - Click Count (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);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
Collection<? extends Callable<T>> tasks) throws InterruptedException { return delegate.invokeAll(wrapTasks(tasks)); } @Override public final <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException { return delegate.invokeAll(wrapTasks(tasks), timeout, unit); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
throws TimeoutException, InterruptedException, ExecutionException { checkNotNull(callable); checkNotNull(timeoutUnit); checkPositiveTimeout(timeoutDuration); Future<T> future = executor.submit(callable); try { return future.get(timeoutDuration, timeoutUnit); } catch (InterruptedException | TimeoutException e) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 9.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
protected OldAbstractFuture() {} /* * Improve the documentation of when InterruptedException is thrown. Our * behavior matches the JDK's, but the JDK's documentation is misleading. */ /** * {@inheritDoc} * * <p>The default {@link AbstractFuture} implementation throws {@code InterruptedException} if * the current thread is interrupted before or during the call, even if the value is already
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
return delegate().offer(e, timeout, unit); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override public void put(E e) throws InterruptedException { delegate().put(e); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3K bytes - Click Count (0)