- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for addTimeoutTarget (0.11 sec)
-
src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
TimeoutManager.getInstance().clear(); } /** * @throws Exception */ public void testExpired() throws Exception { TimeoutTask task = TimeoutManager.getInstance().addTimeoutTarget(new TimeoutTarget() { public void expired() { System.out.println("expired"); expiredCount++; } }, 1, true);
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
cb.query().setJobStatus_Equal(Constants.RUNNING); cb.query().setTarget_Equal(myName); }); } TimeoutManager.getInstance().addTimeoutTarget(() -> { if (logger.isDebugEnabled()) { logger.debug("Updating scheduled jobs. time:{}", schedulerTime); } final long now = systemHelper.getCurrentTimeAsLong();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
} } } protected TimeoutTask createTimeoutTask() { if (timeout <= 0) { return null; } return TimeoutManager.getInstance().addTimeoutTarget(() -> { logger.warn("Process is terminated due to {} second exceeded.", timeout); ComponentUtil.getProcessHelper().destroyProcess(sessionId); processTimeout = true;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 7.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java
TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread()); accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } final ExtractData data = new ExtractData(); final HttpPost httpPost = new HttpPost(url);
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 10K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java
TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new AccessTimeoutTarget(Thread.currentThread()); accessTimeoutTask = TimeoutManager.getInstance().addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); } try { return getResponseData(uri, includeContent); } finally { if (accessTimeoutTarget != null) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 11.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
systemMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getCrawlerSystemMonitorIntervalAsInteger(), true); if (options.hotThread != null) { hotThreadMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new HotThreadMonitorTarget(), options.hotThread, true); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 24K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
destroyContainer(); } }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(), true); final int totalCount = process(options); if (totalCount != 0) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/JobHelper.java
}); } public TimeoutTask startMonitorTask(final JobLog jobLog) { final TimeoutTarget target = new MonitorTarget(jobLog); return TimeoutManager.getInstance().addTimeoutTarget(target, monitorInterval, true); } public void setMonitorInterval(final int monitorInterval) { this.monitorInterval = monitorInterval; }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
* * @param timeoutTarget target * @param timeout timeout * @param permanent permanent * @return {@link TimeoutTask} */ public synchronized TimeoutTask addTimeoutTarget(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) { final TimeoutTask task = new TimeoutTask(timeoutTarget, timeout, permanent); timeoutTaskList.addLast(task); start();
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
destroyContainer(); } }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getSuggestSystemMonitorIntervalAsInteger(), true); exitCode = process(options);
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 10K bytes - Viewed (0)