- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for TimeoutTarget (0.98 sec)
-
src/main/java/org/codelibs/core/timer/TimeoutTarget.java
*/ package org.codelibs.core.timer; /** * This is an interface for handling timeouts. * * @author higa * */ @FunctionalInterface public interface TimeoutTarget { /** * Describes the processing for a timeout. */ void expired();Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 872 bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcConnectionMonitorTarget.java
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.timer.TimeoutTarget; /** * HcConnectionMonitorTarget is responsible for monitoring and managing HTTP client connections. * It implements the TimeoutTarget interface to handle connection expiration events. * * <p>This class uses an instance of HttpClientConnectionManager to manage the connections.
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTask.java
private static final int CANCELED = 2; private final TimeoutTarget timeoutTarget; private final long timeoutMillis; private final boolean permanent; private long startTime; private int status = ACTIVE; TimeoutTask(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) { this.timeoutTarget = timeoutTarget; this.timeoutMillis = timeout * 1000L;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/core/timer/TimeoutManager.java
} /** * Adds a {@link TimeoutTarget}. * * @param timeoutTarget the target * @param timeout the timeout duration * @param permanent whether the task is permanent * @return the {@link TimeoutTask} */ public synchronized TimeoutTask addTimeoutTarget(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {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/main/java/org/codelibs/fess/timer/MonitorTarget.java
import org.codelibs.core.timer.TimeoutTarget; import org.codelibs.fess.Constants; import org.codelibs.fess.helper.SystemHelper; import org.codelibs.fess.taglib.FessFunctions; import org.codelibs.fess.util.ComponentUtil; /** * Abstract base class for monitor targets that implement timeout functionality. */ public abstract class MonitorTarget implements TimeoutTarget { /** * Default constructor.Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.core.timer.TimeoutTarget; /** * AccessTimeoutTarget is a class that implements the TimeoutTarget interface. * It is used to interrupt a running thread when a timeout occurs. * The class provides methods to interrupt the thread and 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/fess/helper/JobHelper.java
public void setMonitorInterval(final int monitorInterval) { this.monitorInterval = monitorInterval; } /** * Inner class that implements TimeoutTarget for monitoring job execution. */ static class MonitorTarget implements TimeoutTarget { /** The job log being monitored */ private final JobLog jobLog; /** * Constructor for MonitorTarget. *
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.9K bytes - Viewed (0) -
src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
} /** * @throws Exception */ public void testExpired() throws Exception { TimeoutTask task = TimeoutManager.getInstance().addTimeoutTarget(new TimeoutTarget() { public void expired() { System.out.println("expired"); expiredCount++; } }, 1, true); assertNotNull(TimeoutManager.getInstance().thread);Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 2.1K bytes - Viewed (0)