- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 247 for InterruptedException (0.06 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java
@Override protected ResponseData getResponseData(final String uri, final boolean includeContent) { try { Thread.sleep(2000); } catch (InterruptedException e) { throw new CrawlingAccessException(e); } return null; } }; client.setAccessTimeout(1); try {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 13.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
"Exception while executing callback: MyListener custom-label", logHandler.getStoredLogRecords().get(0).getMessage()); } public void testEnqueueAndDispatch_multithreaded() throws InterruptedException { Object listener = new Object(); ExecutorService service = newFixedThreadPool(4); ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); try { queue.addListener(listener, service);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
"Exception while executing callback: MyListener custom-label", logHandler.getStoredLogRecords().get(0).getMessage()); } public void testEnqueueAndDispatch_multithreaded() throws InterruptedException { Object listener = new Object(); ExecutorService service = newFixedThreadPool(4); ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); try { queue.addListener(listener, service);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
assertEquals(0, nullCache.size()); CacheTesting.checkEmpty(nullCache.asMap()); } @GwtIncompatible // QueuingRemovalListener public void testRemovalNotification_clear() throws InterruptedException { // If a clear() happens while a computation is pending, we should not get a removal // notification. AtomicBoolean shouldWait = new AtomicBoolean(false);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 25.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
assertEquals(0, nullCache.size()); CacheTesting.checkEmpty(nullCache.asMap()); } @GwtIncompatible // QueuingRemovalListener public void testRemovalNotification_clear() throws InterruptedException { // If a clear() happens while a computation is pending, we should not get a removal // notification. AtomicBoolean shouldWait = new AtomicBoolean(false);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 25K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransactNamedPipeInputStream.java
int result = -1; synchronized (lock) { try { while (used == 0) { lock.wait(); } } catch (final InterruptedException ie) { throw new IOException(ie.getMessage()); } result = pipe_buf[beg_idx] & 0xFF; beg_idx = (beg_idx + 1) % pipe_buf.length; } return result;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 4.6K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
} }); assertTrue(map.isEmpty()); } // ---------------------------------------------------------------- // Test that interrupts result in RuntimeException, not InterruptedException. // Trickier than it looks, because runFinalization swallows interrupts. // ---------------------------------------------------------------- class Interruptenator extends Thread {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 7.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
private volatile boolean completed = false; @Override public void setUp() { builder = new ThreadFactoryBuilder(); } public void testThreadFactoryBuilder_defaults() throws InterruptedException { ThreadFactory threadFactory = builder.build(); Thread thread = threadFactory.newThread(monitoredRunnable); checkThreadPoolName(thread, 1);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertTrue(future.isDone()); assertFalse(future.isCancelled()); } /** Tests that the {@link Future#get(long, TimeUnit)} method times out correctly. */ public void testTimeoutOnGetWorksCorrectly() throws InterruptedException, ExecutionException { // The task thread waits for the latch, so we expect a timeout here. try { future.get(20, MILLISECONDS); fail("Should have timed out trying to get the value.");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.3K bytes - Viewed (0)