Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for rimmed (0.41 sec)

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

      @GwtIncompatible
      @ParametricNullness
      static <T extends @Nullable Object> T invokeAnyImpl(
          ListeningExecutorService executorService,
          Collection<? extends Callable<T>> tasks,
          boolean timed,
          long timeout,
          TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        checkNotNull(executorService);
        checkNotNull(unit);
        int ntasks = tasks.size();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 39K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the
      //   waiters field.
      // * Future completion is defined by when #value becomes non-null/non SetFuture
      // * Future completion can be observed if the waiters field contains a TOMBSTONE
    
      // Timed Get
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractFuture.java

      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on the
      //   waiters field.
      // * Future completion is defined by when #value becomes non-null/non SetFuture
      // * Future completion can be observed if the waiters field contains a TOMBSTONE
    
      // Timed Get
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

                  ListenableFuture<String> a, ListenableFuture<String> b) {
                return successfulAsList(ImmutableSet.of(a, b));
              }
            };
      }
    
      /**
       * Very rough equivalent of a timed get, produced by calling the no-arg get method in another
       * thread and waiting a short time for it.
       *
       * <p>We need this to test the behavior of no-arg get methods without hanging the main test thread
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

                  ListenableFuture<String> a, ListenableFuture<String> b) {
                return successfulAsList(ImmutableSet.of(a, b));
              }
            };
      }
    
      /**
       * Very rough equivalent of a timed get, produced by calling the no-arg get method in another
       * thread and waiting a short time for it.
       *
       * <p>We need this to test the behavior of no-arg get methods without hanging the main test thread
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      //     }
    
      public static long SHORT_DELAY_MS;
      public static long SMALL_DELAY_MS;
      public static long MEDIUM_DELAY_MS;
      public static long LONG_DELAY_MS;
    
      /**
       * Returns the shortest timed delay. This could be reimplemented to use for example a Property.
       */
      protected long getShortDelay() {
        return 50;
      }
    
      /** Sets delays as multiples of SHORT_DELAY. */
      protected void setDelays() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

          ListeningExecutorService executorService,
          Collection<? extends Callable<T>> tasks,
          boolean timed,
          Duration timeout)
          throws InterruptedException, ExecutionException, TimeoutException {
        return invokeAnyImpl(
            executorService, tasks, timed, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 43.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            .matches("[^\\[]+\\[status=SUCCESS, result=\\[java.lang.Boolean@\\w+\\]\\]");
      }
    
      /**
       * This test attempts to cause a future to wait for longer than it was requested to from a timed
       * get() call. As measurements of time are prone to flakiness, it tries to assert based on ranges
       * derived from observing how much time actually passed for various operations.
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        }
      }
    
      private Outcome doCall() {
        boolean guarded = isGuarded(method);
        boolean timed = isTimed(method);
        Object[] arguments = new Object[(guarded ? 1 : 0) + (timed ? 2 : 0)];
        if (guarded) {
          arguments[0] = guard;
        }
        if (timed) {
          arguments[arguments.length - 2] = timeout.millis;
          arguments[arguments.length - 1] = TimeUnit.MILLISECONDS;
        }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Multisets.java

       * Elements are added in encounter order.
       *
       * <p>If the mapped elements contain duplicates (according to {@link Object#equals}), the element
       * will be added more than once, with the count summed over all appearances of the element.
       *
       * <p>Note that {@code stream.collect(toMultiset(function, e -> 1, supplier))} is equivalent to
       * {@code stream.map(function).collect(Collectors.toCollection(supplier))}.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sun Jun 02 13:36:19 UTC 2024
    - 41.6K bytes
    - Viewed (0)
Back to top