- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for service (0.17 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} /** * Add a shutdown hook to wait for thread completion in the given {@link ExecutorService service}. * This is useful if the given service uses daemon threads, and we want to keep the JVM from * exiting immediately on shutdown, instead giving these daemon threads a chance to terminate * normally. * * @param service ExecutorService which uses daemon threads
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
public ServiceManager startAsync() { for (Service service : services) { checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this); } for (Service service : services) { try { state.tryStartTiming(service); service.startAsync(); } catch (IllegalStateException e) { // This can happen if the service has already been started or stopped (e.g. by another
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) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* that sets the name of the thread to the {@linkplain #serviceName() service name}. Also, the * pool will be {@linkplain ScheduledExecutorService#shutdown() shut down} when the service * {@linkplain Service.State#TERMINATED terminates} or {@linkplain Service.State#TERMINATED * fails}. */ protected ScheduledExecutorService executor() { @WeakOuter
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava/src/com/google/common/net/InetAddresses.java
/** * Static utility methods pertaining to {@link InetAddress} instances. * * <p><b>Important note:</b> Unlike {@code InetAddress.getByName()}, the methods of this class never * cause DNS services to be accessed. For this reason, you should prefer these methods as much as * possible over their JDK equivalents whenever you are expecting to handle only IP address string
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 44K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
@J2ktIncompatible @ElementTypesAreNonnullByDefault public abstract class AbstractExecutionThreadService implements Service { private static final LazyLogger logger = new LazyLogger(AbstractExecutionThreadService.class); /* use AbstractService for state management */ private final Service delegate = new AbstractService() { @Override protected final void doStart() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* <p>The delegate future is interrupted and cancelled if it times out. * * @param delegate The future to delegate to. * @param unit the time unit of the time parameter * @param scheduledExecutor The executor service to enforce the timeout. * @since 19.0 */ @J2ktIncompatible @GwtIncompatible // java.util.concurrent.ScheduledExecutorService @SuppressWarnings("GoodTime") // should accept a java.time.Duration
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
final LongHolder holder = new LongHolder(); final ArrayList<ListenableFuture<Integer>> lengthChecks = new ArrayList<>(); final List<Integer> completeLengthChecks; final int baseStackDepth; ExecutorService service = Executors.newFixedThreadPool(5); try { // Avoid counting frames from the executor itself, or the ExecutionSequencer baseStackDepth = serializer .submit(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
final LongHolder holder = new LongHolder(); final ArrayList<ListenableFuture<Integer>> lengthChecks = new ArrayList<>(); final List<Integer> completeLengthChecks; final int baseStackDepth; ExecutorService service = Executors.newFixedThreadPool(5); try { // Avoid counting frames from the executor itself, or the ExecutionSequencer baseStackDepth = serializer .submit(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/net/HttpHeaders.java
public static final String UNSAFE_URL = "unsafe-url"; } /** * The HTTP <a href="https://www.w3.org/TR/service-workers/#update-algorithm">{@code * Service-Worker}</a> header field name. * * @since 20.0 */ public static final String SERVICE_WORKER = "Service-Worker"; /** The HTTP {@code TE} header field name. */ public static final String TE = "TE";
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:08:08 GMT 2024 - 34.3K bytes - Viewed (0)