Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 51 for Wain (0.12 sec)

  1. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code
     * ListenableFuture}</a>.
     *
     * <p>This class is GWT-compatible.
     *
     * <h3>Purpose</h3>
     *
     * <p>The main purpose of {@code ListenableFuture} is to help you chain together a graph of
     * asynchronous operations. You can chain them together manually with calls to methods like {@link
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

                  @Override
                  public void run() {
                    notifyStarted();
                    // We need to wait for the main thread to leave the ServiceManager.startAsync call
                    // to
                    // ensure that the thread running the failure callbacks is not the main thread.
                    Uninterruptibles.awaitUninterruptibly(afterStarted);
                    notifyFailed(new Exception("boom"));
                  }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

         * impossible. We want the test, though, in case that changes in the future,
         * so we use isInstance instead.
         */
        assertFalse(
            "Can't test the main listenInPoolThread path "
                + "if the input is already a ListenableFuture",
            ListenableFuture.class.isInstance(input));
        ListenableFuture<String> listenable = listenInPoolThread(input);
        /*
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionError.java

      /*
       * Ideally, this class would have exposed only constructors that require a non-null cause. See
       * https://github.com/jspecify/jspecify-reference-checker/blob/61aafa4ae52594830cfc2d61c8b113009dbdb045/src/main/java/com/google/jspecify/nullness/NullSpecTransfer.java#L789
       * and https://github.com/jspecify/jspecify/issues/490.
       *
       * (That would also have ensured that its cause was always an Error, rather than possibly another
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Mar 07 17:52:19 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Platform.java

       * would declare a return type of `@Nullable T[]`. However, we've decided not to think too hard
       * about arrays for now, as they're a mess. (We previously discussed this in the review of
       * ObjectArrays, which is the main caller of this method.)
       */
      static <T extends @Nullable Object> T[] newArray(T[] reference, int length) {
        T[] empty = reference.length == 0 ? reference : Arrays.copyOf(reference, 0);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            new CyclicBarrier(
                6 // for the setter threads
                    + 50 // for the listeners
                    + 50 // for the blocking get threads,
                    + 1); // for the main thread
        final ExecutorService executor = Executors.newFixedThreadPool(barrier.getParties());
        final AtomicReference<AbstractFuture<String>> currentFuture = Atomics.newReference();
    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)
  7. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *
     * <p>Here is a simple example of how to use a {@code ServiceManager} to start a server.
     *
     * <pre>{@code
     * class Server {
     *   public static void main(String[] args) {
     *     Set<Service> services = ...;
     *     ServiceManager manager = new ServiceManager(services);
     *     manager.addListener(new Listener() {
     *         public void stopped() {}
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 30.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/reflect/ClassPath.java

        }
      }
    
      /**
       * Returns the class path URIs specified by the {@code Class-Path} manifest attribute, according
       * to <a
       * href="http://docs.oracle.com/javase/8/docs/technotes/guides/jar/jar.html#Main_Attributes">JAR
       * File Specification</a>. If {@code manifest} is null, it means the jar file has no manifest, and
       * an empty set will be returned.
       */
      @VisibleForTesting
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Jan 05 17:43:40 GMT 2022
    - 24.9K bytes
    - Viewed (1)
  9. guava/src/com/google/common/collect/CollectSpliterators.java

        }
      }
    
      /**
       * Implementation of {@link Stream#flatMap} with an object spliterator output type.
       *
       * <p>To avoid having this type, we could use {@code FlatMapSpliterator} directly. The main
       * advantages to having the type are the ability to use its constructor reference below and the
       * parallelism with the primitive version. In short, it makes its caller ({@code flatMap})
       * simpler.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Feb 19 15:21:23 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Cut.java

        private BelowAll() {
          /*
           * No code ever sees this bogus value for `endpoint`: This class overrides both methods that
           * use the `endpoint` field, compareTo() and endpoint(). Additionally, the main implementation
           * of Cut.compareTo checks for belowAll before reading accessing `endpoint` on another Cut
           * instance.
           */
          super("");
        }
    
        @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 12.3K bytes
    - Viewed (0)
Back to top