Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for TimeoutTarget (0.08 sec)

  1. 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: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 872 bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/timer/HotThreadMonitorTargetTest.java

                    MonitorTarget.class.isAssignableFrom(HotThreadMonitorTarget.class));
            assertTrue("HotThreadMonitorTarget should implement TimeoutTarget",
                    TimeoutTarget.class.isAssignableFrom(HotThreadMonitorTarget.class));
        }
    
        public void test_constructor() {
            assertNotNull("Constructor should create instance", target);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 4K bytes
    - Viewed (0)
  3. 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: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  4. 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: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  5. 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/timer/SystemMonitorTargetTest.java

            assertTrue("SystemMonitorTarget should extend MonitorTarget", MonitorTarget.class.isAssignableFrom(SystemMonitorTarget.class));
            assertTrue("SystemMonitorTarget should implement TimeoutTarget", TimeoutTarget.class.isAssignableFrom(SystemMonitorTarget.class));
        }
    
        public void test_constructor() {
            assertNotNull("Constructor should create instance", target);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  7. 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  8. 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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  9. 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: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  10. 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: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.1K bytes
    - Viewed (0)
Back to top