Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 247 for InterruptedException (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/test/java/jcifs/smb/CriticalPerformanceTest.java

                            }
                        }
                        long threadEnd = System.nanoTime();
                        totalTime.addAndGet(threadEnd - threadStart);
    
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    } finally {
                        endLatch.countDown();
                    }
                });
            }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.3K bytes
    - Viewed (0)
Back to top