Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 81 for Sait (0.17 sec)

  1. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * @param timeoutDuration with timeoutUnit, the maximum length of time that callers are willing to
       *     wait on each method call to the proxy
       * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to
       *     wait on each method call to the proxy
       * @return a time-limiting proxy
       * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                                  // WAIT #1
                                  barrier.await(1, TimeUnit.SECONDS);
    
                                  // WAIT #2
                                  barrier.await(1, TimeUnit.SECONDS);
                                  assertTrue(executor.isShutdown());
                                  assertFalse(executor.isTerminated());
    
                                  // WAIT #3
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 28.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

        return queryEarliestAvailable(nowMicros) - timeoutMicros <= nowMicros;
      }
    
      /**
       * Reserves next ticket and returns the wait time that the caller must wait for.
       *
       * @return the required wait time, never negative
       */
      final long reserveAndGetWaitLength(int permits, long nowMicros) {
        long momentAvailable = reserveEarliestAvailable(permits, nowMicros);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Service.java

       */
      void awaitRunning();
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
       * @throws TimeoutException if the service has not reached the given state within the deadline
       * @throws IllegalStateException if the service reaches a state from which it is not possible to
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(TimeUnit.SECONDS.toMillis(10));
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(TimeUnit.SECONDS.toMillis(10));
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

          throws TimeoutException, ExecutionException {
        SettableFuture<String> future = SettableFuture.create();
        future.set(RESULT);
        /*
         * getUninterruptibly should call the timed get method once with a
         * wait of 0 seconds (and it should succeed, since the result is already
         * available).
         */
        assertEquals(RESULT, getUninterruptibly(future, 0, SECONDS));
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

      }
    
      public void testJoinTimeoutMultiInterruptExpired() {
        /*
         * We don't "need" to schedule a thread completion at all here, but by doing
         * so, we come the closest we can to testing that the wait time is
         * appropriately decreased on each progressive join() call.
         */
        TimedThread thread = TimedThread.createWithDelay(LONG_DELAY_MS);
        repeatedlyInterruptTestThread(20, tearDownStack);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 16:06:39 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * </ul>
       *
       * @throws ExecutionException if the computation threw an exception
       * @throws CancellationException if the computation was cancelled
       * @throws TimeoutException if the wait timed out
       * @since 28.0
       */
      @CanIgnoreReturnValue
      @J2ktIncompatible
      @GwtIncompatible // java.time.Duration
      @ParametricNullness
      public static <V extends @Nullable Object> V getUninterruptibly(
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        long nanosPerSecond = NANOSECONDS.convert(1, SECONDS);
        assertThat(nanosPerSecond * Long.MAX_VALUE).isLessThan(0L);
    
        // Check that we wait long enough anyway (presumably as long as MAX_VALUE nanos):
        TimedWaiterThread waiter = new TimedWaiterThread(future, Long.MAX_VALUE, SECONDS);
        waiter.start();
        waiter.awaitWaiting();
    
        future.set(1);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 15.5K bytes
    - Viewed (0)
Back to top