Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for PENDING (0.17 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

          if (!isNullOrEmpty(pendingDescription)) {
            builder.append("PENDING, info=[").append(pendingDescription).append("]");
          } else if (isDone()) {
            addDoneString(builder);
          } else {
            builder.append("PENDING");
          }
        }
        return builder.append("]").toString();
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jan 22 19:37:41 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        AbstractFuture<Object> testFuture3 = new AbstractFuture<Object>() {};
        testFuture3.setFuture(testFuture2);
        assertThat(testFuture3.toString())
            .matches(
                "[^\\[]+\\[status=PENDING, setFuture=\\[[^\\[]+\\[status=PENDING,"
                    + " info=\\[cause=\\[Someday...]]]]]");
        testFuture2.set("result string");
        assertThat(testFuture3.toString())
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        AbstractFuture<Object> testFuture3 = new AbstractFuture<Object>() {};
        testFuture3.setFuture(testFuture2);
        assertThat(testFuture3.toString())
            .matches(
                "[^\\[]+\\[status=PENDING, setFuture=\\[[^\\[]+\\[status=PENDING,"
                    + " info=\\[cause=\\[Someday...]]]]]");
        testFuture2.set("result string");
        assertThat(testFuture3.toString())
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int nextPermitsToAcquire = Math.max(1, random.nextInt(permits));
          permits -= nextPermitsToAcquire;
          rateLimiter.acquire(nextPermitsToAcquire);
        }
        rateLimiter.acquire(1); // to repay for any pending debt
        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

         * `CollectionFuture.values`). This might be a no-op: If this future completed during
         * handleAllCompleted(), they will already have been nulled out. But in the case of
         * whenAll*().call*(), this future may be pending until the callback runs -- or even longer in
         * the case of callAsync(), which waits for the callback's returned future to complete.
         */
        releaseResources(ALL_INPUT_FUTURES_PROCESSED);
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * tasks. Second, the returned list will always be empty, as any submitted task is considered to
       * have started execution. This applies also to tasks given to {@code invokeAll} or {@code
       * invokeAny} which are pending serial execution, even the subset of the tasks that have not yet
       * started execution. It is unclear from the {@code ExecutorService} specification if these should
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

      }
    
      @GwtIncompatible // QueuingRemovalListener
      public void testRemovalNotification_clear() throws InterruptedException {
        // If a clear() happens while a computation is pending, we should not get a removal
        // notification.
    
        final AtomicBoolean shouldWait = new AtomicBoolean(false);
        final CountDownLatch computingLatch = new CountDownLatch(1);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Oct 03 20:10:02 GMT 2023
    - 25.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int nextPermitsToAcquire = Math.max(1, random.nextInt(permits));
          permits -= nextPermitsToAcquire;
          rateLimiter.acquire(nextPermitsToAcquire);
        }
        rateLimiter.acquire(1); // to repay for any pending debt
        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      /**
       * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link
       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
       * method to cancel pending work and then call {@link #notifyStopped} to stop the service.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       (However, cancellation can prevent an <i>unstarted</i> task from running.) Therefore, the
     *       next task will wait for any running callable (or pending {@code Future} returned by an
     *       {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code
     *       cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
Back to top