- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 74 for stopping (0.04 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* blocks, it can prevent this service from changing state. If you need to performing a blocking * operation in order to trigger shutdown, consider instead registering a listener and * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the * same times as {@code triggerShutdown}. */ protected void triggerShutdown() {} /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertFalse(service.startUpCalled); service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync().awaitTerminated(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 12.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
if (state != null) { state.transitionService(service, STARTING, RUNNING); } } @Override public void stopping(State from) { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, from, STOPPING); } } @Override public void terminated(State from) { ServiceManagerState state = this.state.get();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* blocks, it can prevent this service from changing state. If you need to performing a blocking * operation in order to trigger shutdown, consider instead registering a listener and * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the * same times as {@code triggerShutdown}. */ protected void triggerShutdown() {} /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.5K bytes - Viewed (0) -
guava/src/com/google/common/io/Resources.java
*/ public static String toString(URL url, Charset charset) throws IOException { return asCharSource(url, charset).read(); } /** * Streams lines from a URL, stopping when our callback returns false, or we have read all of the * lines. * * @param url the URL to read from * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 7.4K bytes - Viewed (0) -
guava/src/com/google/common/io/CharStreams.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 30 17:25:01 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/general/EditForm.java
* Specified failure types will not be logged or counted as errors. */ @Size(max = 1000) public String ignoreFailureType; /** * Threshold for failure count before stopping crawling of a URL. * Set to -1 to disable the threshold check. */ @Required @Min(-1) @Max(10000) @ValidateTypeFailure public Integer failureCountThreshold; /**
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 9.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
*/ @PreDestroy public void destroy() { for (final String sessionId : runningProcessMap.keySet()) { if (logger.isInfoEnabled()) { logger.info("Stopping process {}", sessionId); } if (destroyProcess(sessionId) == 0 && logger.isInfoEnabled()) { logger.info("Stopped process {}", sessionId); } } }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 9.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
protected void doStart() { // Never starts! } @Override protected void doCancelStart() { assertThat(state()).isEqualTo(Service.State.STOPPING); notifyStopped(); } @Override protected void doStop() { throw new AssertionError(); // Should not be called. } };
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 20:34:52 UTC 2025 - 25.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java
} /** * Stops a running scheduled job. * * @param form the edit form containing the ID of the job to stop * @return HTML response redirecting to the list page after stopping */ @Execute @Secured({ ROLE }) public HtmlResponse stop(final EditForm form) { verifyCrudMode(form.crudMode, CrudMode.DETAILS); final String id = form.id;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 22.2K bytes - Viewed (0)