- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for scheduled (0.04 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
object : Task("task one") { val schedules = mutableListOf(200.µs) override fun runOnce(): Long { if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) // Add it at the end also. } log += "scheduledTasks=${redQueue.scheduledTasks}" return -1L } } redQueue.schedule(task, 100.µs)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 23K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
// If the task is already scheduled, take the earlier of the two times. val existingIndex = futureTasks.indexOf(task) if (existingIndex != -1) { if (task.nextExecuteNanoTime <= executeNanoTime) { taskRunner.logger.taskLog(task, this) { "already scheduled" } return false } futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below! }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java
/** Service for managing scheduled jobs */ @Resource private ScheduledJobService scheduledJobService; /** Pager for paginating scheduled job results */ @Resource private SchedulerPager schedulerPager; /** Helper for processing scheduled jobs. */ @Resource protected ProcessHelper processHelper;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 22.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/JobHelper.java
/** * Registers a scheduled job with the job manager. * * @param scheduledJob the scheduled job to register */ public void register(final ScheduledJob scheduledJob) { final JobManager jobManager = ComponentUtil.getJobManager(); jobManager.schedule(cron -> register(cron, scheduledJob)); } /** * Registers a scheduled job with the specified cron scheduler. *
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/fess/app/web/admin/scheduler/CreateForm.java
/** * The sort order for displaying this scheduled job. */ @Required @Min(value = 0) @Max(value = 2147483647) @ValidateTypeFailure public Integer sortOrder; /** * The username of who created this scheduled job. */ @Size(max = 1000) public String createdBy; /** * The timestamp when this scheduled job was created. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ScheduledJobService.java
} /** * Gets a scheduled job by its ID. * @param id The ID of the scheduled job. * @return An optional entity of the scheduled job. */ public OptionalEntity<ScheduledJob> getScheduledJob(final String id) { return scheduledJobBhv.selectByPK(id); } /** * Deletes a scheduled job. * @param scheduledJob The scheduled job to delete. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/pager/SchedulerPager.java
*/ public String scriptType; /** * Whether the scheduled job is a crawler job. */ public String crawler; /** * Whether logging is enabled for the scheduled job. */ public String jobLogging; /** * Whether the scheduled job is available. */ public String available; /** * Sort order of the scheduled job.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
private ScheduledFuture<@Nullable Void> submitToExecutor(Schedule schedule) { return executor.schedule(this, schedule.delay, schedule.unit); } } /** * Contains the most recently submitted {@code Future}, which may be cancelled or updated, * always under a lock. */ private static final class SupplantableFuture implements Cancellable { private final ReentrantLock lock;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
} /** * Retrieves scheduler settings with pagination. * * @param body the search parameters for filtering and pagination * @return JSON response containing scheduler settings list */ // GET /api/admin/scheduler // PUT /api/admin/scheduler @Execute public JsonResponse<ApiResult> settings(final SearchBody body) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 10K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java
@Resource private JobHelper jobHelper; /** The job class to be executed by this scheduler */ protected Class<? extends LaJob> jobClass = ScriptExecutorJob.class; /** The timestamp when the scheduler was last updated */ protected long schedulerTime; @Override public void schedule(final LaCron cron) { schedulerTime = 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)