- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for renamingDecorator (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 16:22:21 UTC 2024 - 27.8K bytes - Viewed (0)