Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for rimmed (0.22 sec)

  1. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        runUntimedInterruptsTest(38);
      }
    
      public void testMakeUninterruptible_timed_uninterrupted() throws Exception {
        runTimedInterruptsTest(0);
      }
    
      public void testMakeUninterruptible_timed_interrupted() throws Exception {
        runTimedInterruptsTest(1);
      }
    
      public void testMakeUninterruptible_timed_multiplyInterrupted() throws Exception {
        runTimedInterruptsTest(38);
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/cache/RemovalListener.java

    /**
     * An object that can receive a notification when an entry is removed from a cache. The removal
     * resulting in notification could have occurred to an entry being manually removed or replaced, or
     * due to eviction resulting from timed expiration, exceeding a maximum size, or garbage collection.
     *
     * <p>An instance may be called concurrently by multiple threads to process different entries.
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Tue Jun 15 18:00:07 GMT 2021
    - 2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

            assertThrows(
                TimeoutException.class,
                () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS));
        assertThat(e)
            .hasMessageThat()
            .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state.");
      }
    
      private static class TestService extends AbstractIdleService {
        int startUpCalled = 0;
        int shutDownCalled = 0;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        // 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.");
        } catch (TimeoutException expected) {
        } finally {
          latch.countDown();
        }
      }
    
      /**
       * Tests that a canceled future throws a cancellation exception.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

          } else {
            try {
              ScheduledFuture<?> timer = timeoutFuture.timer;
              timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString()
              String message = "Timed out";
              // This try-finally block ensures that we complete the timeout future, even if attempting
              // to produce the message throws (probably StackOverflowError from delegate.toString())
              try {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        runUntimedInterruptsTest(38);
      }
    
      public void testMakeUninterruptible_timed_uninterrupted() throws Exception {
        runTimedInterruptsTest(0);
      }
    
      public void testMakeUninterruptible_timed_interrupted() throws Exception {
        runTimedInterruptsTest(1);
      }
    
      public void testMakeUninterruptible_timed_multiplyInterrupted() throws Exception {
        runTimedInterruptsTest(38);
      }
    
    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)
  7. android/guava/src/com/google/common/cache/RemovalListener.java

    /**
     * An object that can receive a notification when an entry is removed from a cache. The removal
     * resulting in notification could have occurred to an entry being manually removed or replaced, or
     * due to eviction resulting from timed expiration, exceeding a maximum size, or garbage collection.
     *
     * <p>An instance may be called concurrently by multiple threads to process different entries.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Jun 15 18:00:07 GMT 2021
    - 2K bytes
    - Viewed (0)
  8. .github/ISSUE_TEMPLATE/feature_addition_request.yaml

            features down to compact but powerful abstractions, and controlling feature bloat carefully.
    
    
            Guava's main yardstick for evaluating proposed features can be summed up as [utility times
            ubiquity](https://github.com/google/guava/wiki/PhilosophyExplained#utility-times-ubiquity).
    
    
            #### Utility: compare with alternatives
    
    
    Others
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Nov 17 18:47:47 GMT 2023
    - 5.8K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        // 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.");
        } catch (TimeoutException expected) {
        } finally {
          latch.countDown();
        }
      }
    
      /**
       * Tests that a canceled future throws a cancellation exception.
       *
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

            assertThrows(
                TimeoutException.class,
                () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS));
        assertThat(e)
            .hasMessageThat()
            .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state.");
      }
    
      private static class TestService extends AbstractIdleService {
        int startUpCalled = 0;
        int shutDownCalled = 0;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
Back to top