Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for renamingDecorator (0.1 sec)

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

      private final Service delegate = new DelegateService();
    
      @WeakOuter
      private final class DelegateService extends AbstractService {
        @Override
        protected final void doStart() {
          MoreExecutors.renamingDecorator(executor(), threadNameSupplier)
              .execute(
                  () -> {
                    try {
                      startUp();
                      notifyStarted();
                    } catch (Throwable t) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 13:59:28 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  2. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. 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(final Executor executor, final Supplier<String> nameSupplier) {
        checkNotNull(executor);
        checkNotNull(nameSupplier);
        return new Executor() {
          @Override
          public void execute(Runnable command) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      /* use AbstractService for state management */
      private final Service delegate =
          new AbstractService() {
            @Override
            protected final void doStart() {
              Executor executor = MoreExecutors.renamingDecorator(executor(), () -> serviceName());
              executor.execute(
                  () -> {
                    try {
                      startUp();
                      notifyStarted();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
Back to top