Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 247 for InterruptedException (0.14 sec)

  1. src/test/java/jcifs/internal/witness/WitnessRegistrationTest.java

            assertEquals(2, seq2);
            assertEquals(3, seq3);
            assertTrue(seq2 > seq1);
            assertTrue(seq3 > seq2);
        }
    
        @Test
        void testHeartbeatUpdate() throws InterruptedException {
            long initialTime = registration.getLastHeartbeat();
    
            Thread.sleep(50); // Ensure sufficient time difference
            registration.updateHeartbeat();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 09:06:40 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java

            assertTrue(leaseManager.getAllLeases().isEmpty());
        }
    
        @Test
        @DisplayName("Should clean up expired leases")
        void testCleanupExpiredLeases() throws InterruptedException {
            String path = "/share/expired.txt";
            int requestedState = Smb2LeaseState.SMB2_LEASE_READ_CACHING;
    
            Smb2LeaseKey key = leaseManager.requestLease(path, requestedState);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 00:16:17 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      }
    
      @ParametricNullness
      @SuppressWarnings("nullness") // TODO(b/147136275): Remove once our checker understands & and |.
      final V blockingGet() throws InterruptedException, ExecutionException {
        if (Thread.interrupted()) {
          throw new InterruptedException();
        }
        @RetainedLocalRef Object localValue = valueField;
        if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  4. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                            for (int j = 0; j < operationsPerThread; j++) {
                                crawlerContext.incrementAndGetAccessCount();
                            }
                        } catch (InterruptedException e) {
                            Thread.currentThread().interrupt();
                        } finally {
                            endLatch.countDown();
                        }
                    }
                });
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Queues.java

       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
       * @return the number of elements transferred
       * @throws InterruptedException if interrupted while waiting
       * @since 33.4.0 (but since 28.0 in the JRE flavor)
       */
      @CanIgnoreReturnValue
      @J2ktIncompatible
      @GwtIncompatible // BlockingQueue
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  6. android/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)
  7. 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)
  8. guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/TestPlatform.java

          throws ExecutionException {
        checkState(future.isDone(), "Future was expected to be done: %s", future);
        try {
          return future.get(0, SECONDS);
        } catch (InterruptedException e) {
          throw new AssertionError();
        } catch (TimeoutException e) {
          throw new AssertionError();
        }
      }
    
      private TestPlatform() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        @Override
        public void await() throws InterruptedException {
          lock.lock();
          try {
            condition.await();
          } finally {
            lock.unlock();
          }
        }
    
        @Override
        public boolean await(long time, TimeUnit unit) throws InterruptedException {
          lock.lock();
          try {
            return condition.await(time, unit);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

      }
    
      public void testExecute_idempotentConcurrently() throws InterruptedException {
        CountDownLatch okayToRun = new CountDownLatch(1);
        AtomicInteger runCalled = new AtomicInteger();
        list.add(
            new Runnable() {
              @Override
              public void run() {
                try {
                  okayToRun.await();
                } catch (InterruptedException e) {
                  Thread.currentThread().interrupt();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.7K bytes
    - Viewed (0)
Back to top