Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for renamingDecorator (0.06 sec)

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

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.newThread;
    import static com.google.common.util.concurrent.MoreExecutors.renamingDecorator;
    import static com.google.common.util.concurrent.Platform.restoreInterruptIfIsInterruptedException;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.newThread;
    import static com.google.common.util.concurrent.MoreExecutors.renamingDecorator;
    import static com.google.common.util.concurrent.Platform.restoreInterruptIfIsInterruptedException;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator;
    import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
    import static com.google.common.util.concurrent.MoreExecutors.renamingDecorator;
    import static com.google.common.util.concurrent.MoreExecutors.shutdownAndAwaitTermination;
    import static java.util.concurrent.TimeUnit.DAYS;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *
       * @param executor The executor to decorate
       * @param nameSupplier The source of names for each task
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      static Executor renamingDecorator(Executor executor, Supplier<String> nameSupplier) {
        checkNotNull(executor);
        checkNotNull(nameSupplier);
        return command -> executor.execute(threadRenaming(command, nameSupplier));
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator;
    import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
    import static com.google.common.util.concurrent.MoreExecutors.renamingDecorator;
    import static com.google.common.util.concurrent.MoreExecutors.shutdownAndAwaitTermination;
    import static java.util.concurrent.TimeUnit.DAYS;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
          }
        }
    
        private final Runnable task = new Task();
    
        @Override
        protected final void doStart() {
          executorService =
              MoreExecutors.renamingDecorator(executor(), () -> serviceName() + " " + state());
          executorService.execute(
              () -> {
                lock.lock();
                try {
                  startUp();
                  /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
          }
        }
    
        private final Runnable task = new Task();
    
        @Override
        protected final void doStart() {
          executorService =
              MoreExecutors.renamingDecorator(executor(), () -> serviceName() + " " + state());
          executorService.execute(
              () -> {
                lock.lock();
                try {
                  startUp();
                  /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
Back to top