- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 366 for stopFn (0.04 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java
* The class provides methods to interrupt the thread and stop the timeout target. * * <p> * The class uses a logger to log debug messages. * It also uses an AtomicBoolean to track whether the thread is running. * </p> * * <p> * The expired method is called when a timeout occurs. * It interrupts the running thread up to a maximum number of times. * The stop method is called to stop the timeout target. * </p> */
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
thread.start(); if (logger.isDebugEnabled()) { logger.debug("TimeoutManager started."); } } } /** * Stops the process. */ public synchronized void stop() { if (thread != null) { thread.interrupt(); thread = null; if (logger.isDebugEnabled()) { logger.debug("TimeoutManager stopped.");
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 7.8K bytes - Viewed (0) -
src/bufio/scan.go
// // Scanning stops if the function returns an error, in which case some of // the input may be discarded. If that error is [ErrFinalToken], scanning // stops with no error. A non-nil token delivered with [ErrFinalToken] // will be the last token, and a nil token with [ErrFinalToken] // immediately stops the scanning. //
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed May 21 18:05:26 UTC 2025 - 14.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)
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Nov 01 21:52:12 UTC 2024 - 5.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTask.java
* * @return whether the task is stopped */ public boolean isStopped() { return status == STOPPED; } /** * Stops the timer. */ public void stop() { if (status != ACTIVE) { throw new ClIllegalStateException(String.valueOf(status)); } status = STOPPED; } /** * Restarts the timer.Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 2.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
} /** * Stops a scheduled job by ID. * * @param id the ID of the scheduled job to stop * @return JSON response indicating success or failure */ // PUT /api/admin/scheduler/{id}/stop @Execute(urlPattern = "{}/@word") public JsonResponse<ApiResult> put$stop(final String id) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sun Nov 23 12:34:02 UTC 2025 - 10.1K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
startTick = ticker.read(); return this; } /** * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this * point. * * @return this {@code Stopwatch} instance * @throws IllegalStateException if the stopwatch is already stopped. */ @CanIgnoreReturnValue public Stopwatch stop() { long tick = ticker.read();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 9.2K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbCopyUtilTest.java
verify(out, timeout(1000)).write(payload, 0, 3); // Stop the thread by sending n = -1 synchronized (w) { w.write(new byte[0], -1, out); } w.join(2000); assertFalse(w.isAlive(), "WriterThread should stop after -1 sentinel"); } @Test @DisplayName("WriterThread surfaces SmbException via checkException")
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
} } /** * Forces all crawlers to stop immediately. * Sets the force stop flag and stops all active crawler instances. */ private void forceStop() { systemHelper.setForceStop(true); if (crawlerList != null) { for (final Crawler crawler : crawlerList) { crawler.stop(); } } } /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 32.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java
}); return redirect(getClass()); } /** * 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, this::asListHtml);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 20 13:56:35 UTC 2025 - 21.8K bytes - Viewed (0)