Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for WAITING (0.16 sec)

  1. android/guava/src/com/google/common/util/concurrent/Monitor.java

       *
       * @throws InterruptedException if interrupted while waiting
       */
      public void enterInterruptibly() throws InterruptedException {
        lock.lockInterruptibly();
      }
    
      /**
       * Enters this monitor. Blocks at most the given time, and may be interrupted.
       *
       * @return whether the monitor was entered
       * @throws InterruptedException if interrupted while waiting
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

     * ordinary tests.
     *
     * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time
     * period or an interrupt while waiting for the expected event will result in a {@link
     * RuntimeException}.
     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
     * final CountDownLatch latch = new CountDownLatch(1);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        SATISFIED_AND_OCCUPIED_BEFORE_ENTERING,
        SATISFIED_UNOCCUPIED_AND_INTERRUPTED_BEFORE_ENTERING,
    
        SATISFIED_BEFORE_WAITING,
        SATISFIED_WHILE_WAITING,
        SATISFIED_AND_INTERRUPTED_BEFORE_WAITING,
        UNSATISFIED_BEFORE_AND_WHILE_WAITING,
        UNSATISFIED_AND_INTERRUPTED_BEFORE_WAITING;
    
        @Override
        public String toString() {
          return CaseFormat.UPPER_UNDERSCORE.to(CaseFormat.UPPER_CAMEL, name());
        }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 27.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        SATISFIED_AND_OCCUPIED_BEFORE_ENTERING,
        SATISFIED_UNOCCUPIED_AND_INTERRUPTED_BEFORE_ENTERING,
    
        SATISFIED_BEFORE_WAITING,
        SATISFIED_WHILE_WAITING,
        SATISFIED_AND_INTERRUPTED_BEFORE_WAITING,
        UNSATISFIED_BEFORE_AND_WHILE_WAITING,
        UNSATISFIED_AND_INTERRUPTED_BEFORE_WAITING;
    
        @Override
        public String toString() {
          return CaseFormat.UPPER_UNDERSCORE.to(CaseFormat.UPPER_CAMEL, name());
        }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       * state: BLOCKED, WAITING, or TIMED_WAITING.
       */
      void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) {
        long startTime = System.nanoTime();
        for (; ; ) {
          Thread.State s = thread.getState();
          if (s == Thread.State.BLOCKED || s == Thread.State.WAITING || s == Thread.State.TIMED_WAITING)
            return;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.7K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/testing/GcFinalization.java

     * ordinary tests.
     *
     * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time
     * period or an interrupt while waiting for the expected event will result in a {@link
     * RuntimeException}.
     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
     * final CountDownLatch latch = new CountDownLatch(1);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    public final class InterruptibleTaskTest extends TestCase {
    
      // Regression test for a deadlock where a task could be stuck busy waiting for the task to
      // transition to DONE
      public void testInterruptThrows() throws Exception {
        final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1);
        InterruptibleTask<@Nullable Void> task =
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * throttled threads will <b>not</b> be awakened as a result of this invocation, thus they do not
       * observe the new rate; only subsequent requests will.
       *
       * <p>Note though that, since each request repays (by waiting, if necessary) the cost of the
       * <i>previous</i> request, this means that the very next request after an invocation to {@code
       * setRate} will not be affected by the new rate; it will pay the cost of the previous request,
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

                    }
                  });
          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
        gettersComplete.await();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 86.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      protected static final int SLOW_FUNC_VALID_INPUT_DATA = 3;
      private static final String RESULT_DATA = "SUCCESS";
    
      private SettableFuture<String> outputFuture;
      // Signals that the function is waiting to complete
      private CountDownLatch funcIsWaitingLatch;
      // Signals the function so it will complete
      private CountDownLatch funcCompletionLatch;
    
      @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
Back to top