- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 596 for stop (0.17 sec)
-
android/guava/src/com/google/common/io/ByteProcessor.java
/** * A callback interface to process bytes from a stream. * * <p>{@link #processBytes} will be called for each chunk of data that is read, and should return * {@code false} when you want to stop processing. * * @author Chris Nokleberg * @since 1.0 */ @DoNotMock("Implement it normally") @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
return asJson(new ApiResponse().status(Status.OK).result()); } // POST /api/admin/scheduler/{id}/stop @Execute(urlPattern = "{}/@word") public JsonResponse<ApiResult> post$stop(final String id) { scheduledJobService.getScheduledJob(id).ifPresent(entity -> { try { entity.stop(); } catch (final Exception e) { logger.warn("Failed to process a request.", e);
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Stopwatch.java
* <pre>{@code * Stopwatch stopwatch = Stopwatch.createStarted(); * doSomething(); * stopwatch.stop(); // optional * * long millis = stopwatch.elapsed(MILLISECONDS); * * log.info("time: " + stopwatch); // formatted string like "12.3 ms" * }</pre> * * <p>The state-changing methods are not idempotent; it is an error to start or stop a stopwatch * that is already in the desired state. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Nov 15 21:38:09 GMT 2022 - 8.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} log.Info("CNI ambient server marking ready") s.Ready() s.dataplane.Start(s.ctx) s.handlers.Start() } func (s *Server) Stop() { log.Info("CNI ambient server terminating, cleaning up node net rules") s.cniServerStopFunc() s.dataplane.Stop() } type meshDataplane struct { kubeClient kubernetes.Interface netServer MeshDataplane }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
src/bufio/example_test.go
return 0, data, bufio.ErrFinalToken } // If the token is "STOP", stop the scanning and ignore the rest. if string(data[:i]) == "STOP" { return i + 1, nil, bufio.ErrFinalToken } // Otherwise, return the token before the comma. return i + 1, data[:i], nil } const input = "1,2,STOP,4," scanner := bufio.NewScanner(strings.NewReader(input)) scanner.Split(onComma)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 4.9K bytes - Viewed (0) -
src/main/resources/fess_indices/fess/zh-tw/stopwords.txt
》 — - , 。 、 : ; ! · ? “ ” ) ( 【 】 [ ] ● # the line below contains an IDEOGRAPHIC SPACE character (Used as a space in Chinese) # English Stop Words
Plain Text - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Sat Jun 17 08:00:22 GMT 2017 - 310 bytes - Viewed (0) -
cmd/callhome.go
defer callhomeTimer.Stop() for { if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } select { case <-ctx.Done(): // indicates that we do not need to run callhome anymore return false case <-callhomeTimer.C: if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
src/main/assemblies/files/service.bat
if /i %SERVICE_CMD% == remove goto doRemove if /i %SERVICE_CMD% == start goto doStart if /i %SERVICE_CMD% == stop goto doStop if /i %SERVICE_CMD% == manager goto doManagment echo Unknown option "%SERVICE_CMD%" :displayUsage echo. echo Usage: service.bat install^|remove^|start^|stop^|manager [SERVICE_ID] goto:eof :doStart "%EXECUTABLE%" //ES//%SERVICE_ID% %LOG_OPTS% if not errorlevel 1 goto started
Batch File - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Sun Jan 15 06:32:15 GMT 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
// stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown();
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
// stop it. blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0)