Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for listeningDecorator (0.13 sec)

  1. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       * future is {@linkplain Future#isDone() done}.
       *
       * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link
       * MoreExecutors#listeningDecorator( java.util.concurrent.ExecutorService)}, {@link
       * ListenableFutureTask}, {@link AbstractFuture}, and other utilities over creating plain {@code
       * Future} instances to be upgraded to {@code ListenableFuture} after the fact.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        List<? extends Future<?>> unused = executor.invokeAll(tasks);
      }
    
      public void testListeningDecorator() throws Exception {
        ListeningExecutorService service = listeningDecorator(newDirectExecutorService());
        assertSame(service, listeningDecorator(service));
        List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
        List<Future<String>> results;
    
        results = service.invokeAll(callables);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        List<? extends Future<?>> unused = executor.invokeAll(tasks);
      }
    
      public void testListeningDecorator() throws Exception {
        ListeningExecutorService service = listeningDecorator(newDirectExecutorService());
        assertSame(service, listeningDecorator(service));
        List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
        List<Future<String>> results;
    
        results = service.invokeAll(callables);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       * future is {@linkplain Future#isDone() done}.
       *
       * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link
       * MoreExecutors#listeningDecorator( java.util.concurrent.ExecutorService)}, {@link
       * ListenableFutureTask}, {@link AbstractFuture}, and other utilities over creating plain {@code
       * Future} instances to be upgraded to {@code ListenableFuture} after the fact.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

     * {@code ExecutorService} methods. To create an instance from an existing {@link
     * ScheduledExecutorService}, call {@link
     * MoreExecutors#listeningDecorator(ScheduledExecutorService)}.
     *
     * @author Chris Povirk
     * @since 10.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public interface ListeningScheduledExecutorService
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *       service to a {@link ListeningExecutorService}, usually by calling {@link
     *       MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)
     *       MoreExecutors.listeningDecorator}.
     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

      @GwtIncompatible // TODO
      public static ListeningExecutorService listeningDecorator(ExecutorService delegate) {
        return (delegate instanceof ListeningExecutorService)
            ? (ListeningExecutorService) delegate
            : (delegate instanceof ScheduledExecutorService)
                ? new ScheduledListeningDecorator((ScheduledExecutorService) delegate)
                : new ListeningDecorator(delegate);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  8. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     *       service to a {@link ListeningExecutorService}, usually by calling {@link
     *       MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)
     *       MoreExecutors.listeningDecorator}.
     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *       service to a {@link ListeningExecutorService}, usually by calling {@link
     *       MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)
     *       MoreExecutors.listeningDecorator}.
     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

     * {@code ExecutorService}. Most users should call {@link ListeningExecutorService#submit(Callable)
     * ListeningExecutorService.submit} on a service obtained from {@link
     * MoreExecutors#listeningDecorator}.
     *
     * @author Sven Mawson
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public class ListenableFutureTask<V extends @Nullable Object> extends FutureTask<V>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.3K bytes
    - Viewed (0)
Back to top