Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 298 for seconds (0.07 sec)

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

            "foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class, 0, SECONDS));
      }
    
      public void testGetCheckedTimed_interrupted() {
        SettableFuture<String> future = SettableFuture.create();
        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class, 0, SECONDS);
          fail();
        } catch (TwoArgConstructorException expected) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                                  barrier.await(1, SECONDS);
    
                                  // WAIT #2
                                  barrier.await(1, SECONDS);
                                  assertTrue(executor.isShutdown());
                                  assertFalse(executor.isTerminated());
    
                                  // WAIT #3
                                  barrier.await(1, SECONDS);
                                  return null;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        assertTrue(limiter.tryAcquire(0, SECONDS));
        assertFalse(limiter.tryAcquire(0, SECONDS));
        assertFalse(limiter.tryAcquire(0, SECONDS));
        stopwatch.sleepMillis(100);
        assertFalse(limiter.tryAcquire(0, SECONDS));
      }
    
      public void testTryAcquire_someWaitAllowed() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        assertTrue(limiter.tryAcquire(0, SECONDS));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        assertTrue(limiter.tryAcquire(0, SECONDS));
        assertFalse(limiter.tryAcquire(0, SECONDS));
        assertFalse(limiter.tryAcquire(0, SECONDS));
        stopwatch.sleepMillis(100);
        assertFalse(limiter.tryAcquire(0, SECONDS));
      }
    
      public void testTryAcquire_someWaitAllowed() {
        RateLimiter limiter = RateLimiter.create(5.0, stopwatch);
        assertTrue(limiter.tryAcquire(0, SECONDS));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

      }
    
      public void testTimeToLive_setTwice() {
        CacheBuilder<Object, Object> builder =
            CacheBuilder.newBuilder().expireAfterWrite(3600, SECONDS);
        assertThrows(IllegalStateException.class, () -> builder.expireAfterWrite(3600, SECONDS));
      }
    
      @GwtIncompatible // Duration
      public void testTimeToLive_setTwice_duration() {
        CacheBuilder<Object, Object> builder =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * second" (commonly referred to as <i>QPS</i>, queries per second).
       *
       * <p>The returned {@code RateLimiter} ensures that on average no more than {@code
       * permitsPerSecond} are issued during any given second, with sustained requests being smoothly
       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                                  barrier.await(1, SECONDS);
    
                                  // WAIT #2
                                  barrier.await(1, SECONDS);
                                  assertTrue(executor.isShutdown());
                                  assertFalse(executor.isTerminated());
    
                                  // WAIT #3
                                  barrier.await(1, SECONDS);
                                  return null;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/RateLimiter.java

       * second" (commonly referred to as <i>QPS</i>, queries per second).
       *
       * <p>The returned {@code RateLimiter} ensures that on average no more than {@code
       * permitsPerSecond} are issued during any given second, with sustained requests being smoothly
       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java

      public void testParse_writeExpirationSeconds() {
        CacheBuilderSpec spec = parse("expireAfterWrite=10s");
        assertEquals(SECONDS, spec.writeExpirationTimeUnit);
        assertEquals(10L, spec.writeExpirationDuration);
        assertCacheBuilderEquivalence(
            CacheBuilder.newBuilder().expireAfterWrite(10L, SECONDS), CacheBuilder.from(spec));
      }
    
      public void testParse_writeExpirationRepeated() {
        assertThrows(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

          return;
        }
        long timeoutSeconds = timeoutSeconds();
        long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds);
        do {
          System.runFinalization();
          if (future.isDone()) {
            return;
          }
          System.gc();
          try {
            future.get(1L, SECONDS);
            return;
          } catch (CancellationException | ExecutionException ok) {
            return;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
Back to top