- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for addTimeoutTarget (0.93 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 Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 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 Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.3K 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 Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 14.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
} }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance() .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(), true); final int totalCount = process(options);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 9.3K 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); } /** * Sets the monitor interval for job monitoring. * * @param monitorInterval the monitor interval in seconds */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 10.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
* @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) { final TimeoutTask task = new TimeoutTask(timeoutTarget, timeout, permanent); timeoutTaskList.addLast(task); start();
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 7.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 Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 31K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/FileUtil.java
* * @param file * The file to delete. */ public static void deleteInBackground(final File file) { if (file != null) { TimeoutManager.getInstance().addTimeoutTarget(() -> { try { Files.deleteIfExists(file.toPath()); } catch (final IOException e) { throw new IORuntimeException(e); }
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 8.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
} }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance() .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getSuggestSystemMonitorIntervalAsInteger(), true); exitCode = process(options);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 11K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
logger.debug("role: {}", roleSet); } final String[] roles = roleSet.toArray(new String[roleSet.size()]); if (!subRoleSet.isEmpty()) { TimeoutManager.getInstance().addTimeoutTarget(() -> { sAMAccountGroupNameSet.stream().forEach(groupName -> { getSAMAccountGroupName(bindDn, groupName).ifPresent(sAMAccountGroupName -> {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 82K bytes - Viewed (0)