- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for Task (0.12 sec)
-
src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java
logger.debug("Job {} is running.", id); } return; } TimeoutTask task = null; try { if (scheduledJob.isLoggingEnabled()) { jobHelper.store(jobLog); task = jobHelper.startMonitorTask(jobLog); } if (logger.isDebugEnabled()) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/PingResponse.java
private static final String NUMBER_OF_IN_FLIGHT_FETCH = "number_of_in_flight_fetch"; private static final String DELAYED_UNASSIGNED_SHARDS = "delayed_unassigned_shards"; private static final String TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS = "task_max_waiting_in_queue_millis"; private static final String ACTIVE_SHARDS_PERCENT_AS_NUMBER = "active_shards_percent_as_number"; private static final String ACTIVE_PRIMARY_SHARDS = "active_primary_shards";
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java
Thread.sleep(10); int count = expiredCount; task.stop(); TimeoutManager.getInstance().start(); assertNotNull(TimeoutManager.getInstance().thread); Thread.sleep(2000); assertEquals(count, expiredCount); assertEquals(1, TimeoutManager.getInstance().getTimeoutTaskCount()); task.cancel(); Thread.sleep(2000);
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/common/ImplementedInvokerAssistant.java
// ========= protected static final String[] DEFAULT_CLIENT_INVOKE_NAMES = { "Page", "Action", "Controller", "ControllerImpl", "Task", "Test" }; protected static final String[] DEFAULT_BYPASS_INVOKE_NAMES = { "Service", "ServiceImpl", "Facade", "FacadeImpl", "Logic", "LogicImpl" }; @Override public DBDef assistCurrentDBDef() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java
final Tuple3<String, String, String> task = generator.createTask(path, docMap); if (task != null) { if (logger.isDebugEnabled()) { logger.debug("Add thumbnail task: {}", task); } if (!thumbnailTaskQueue.offer(task)) { logger.warn("Failed to add thumbnail task: {}", task); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 21.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java
} public static void execute(final Runnable task) { ForkJoinPool.commonPool().execute(() -> { final Thread currentThread = Thread.currentThread(); final ClassLoader orignal = currentThread.getContextClassLoader(); currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader()); try { task.run(); } catch (final Exception e) {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K bytes - Viewed (1) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
final TimeoutTask task = e.getElement(); if (task.isCanceled()) { e.remove(); } else if (!task.isStopped() && task.isExpired()) { expiredTask.add(task); if (!task.isPermanent()) { e.remove(); } } }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/samr.java
} public int retval; public String system_name; public int access_mask; public rpc.policy_handle handle; public SamrConnect2 ( String system_name, int access_mask, rpc.policy_handle handle ) { this.system_name = system_name; this.access_mask = access_mask; this.handle = handle; } @Override
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:40:13 GMT 2019 - 15.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/ACE.java
* and access mask of each ACE. If the SID matches, the allow/deny flags * and access mask are considered. If the ACE is a "deny" * ACE and <i>any</i> of the desired access bits match bits in the access * mask of the ACE, the whole access check fails. If the ACE is an "allow" * ACE and <i>all</i> of the bits in the desired access bits match bits in * the access mask of the ACE, the access check is successful. Otherwise,
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 7.2K bytes - Viewed (0)