Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 152 for scheduled (0.62 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top