Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for ending1 (0.28 sec)

  1. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.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 19 12:43:09 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Striped.java

         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
         * If we only held the int[] stripes, translating it on the fly to L's, the original locks might
         * be garbage collected after locking them, ending up in a huge mess.
         */
        @SuppressWarnings("unchecked") // we carefully replaced all keys with their respective L's
        List<L> asStripes = (List<L>) result;
        return Collections.unmodifiableList(asStripes);
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 10 20:55:18 GMT 2023
    - 20.3K bytes
    - Viewed (1)
  3. 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)
  4. guava-tests/test/com/google/common/base/SplitterTest.java

        String regexPattern = "(?<=:)";
        Iterable<String> split = Splitter.onPattern(regexPattern).split(toSplit);
        assertThat(split).containsExactly(":", "foo:", ":", "barbaz:").inOrder();
        // splits into chunks ending in :
      }
    
      @J2ktIncompatible // Kotlin Native's regex is based on Apache Harmony, like old Android
      @GwtIncompatible // java.util.regex.Pattern
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 29.8K bytes
    - Viewed (0)
  5. 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)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

          InCompletionOrderState<T> localState = state;
          if (super.cancel(interruptIfRunning)) {
            /*
             * requireNonNull is generally safe: If cancel succeeded, then this Future was still
             * pending, so its `state` field hasn't been nulled out yet.
             *
             * OK, it's technically possible for this to fail in the presence of unsafe publishing, as
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/Preconditions.java

       * size}, inclusive.
       *
       * @param start a user-supplied index identifying a starting position in an array, list or string
       * @param end a user-supplied index identifying an ending position in an array, list or string
       * @param size the size of that array, list or string
       * @throws IndexOutOfBoundsException if either index is negative or is greater than {@code size},
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Wed Feb 14 15:46:55 GMT 2024
    - 52.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

      /**
       * @return a {@code ListenableFuture} representing pending completion of the task
       * @throws RejectedExecutionException {@inheritDoc}
       */
      @Override
      <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task);
    
      /**
       * @return a {@code ListenableFuture} representing pending completion of the task
       * @throws RejectedExecutionException {@inheritDoc}
       */
      @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Sun Jun 20 10:45:35 GMT 2021
    - 4.2K bytes
    - Viewed (0)
  9. 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)
  10. android/guava/src/com/google/common/cache/LocalCache.java

        @Override
        public void notifyNewValue(@CheckForNull V newValue) {
          if (newValue != null) {
            // The pending load was clobbered by a manual write.
            // Unblock all pending gets, and have them return the new value.
            set(newValue);
          } else {
            // The pending load was removed. Delay notifications until loading completes.
            oldValue = unset();
          }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 144.7K bytes
    - Viewed (0)
Back to top