* ----------
 *
 * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the
 * task should not be executed again. Otherwise it returns a delay until the next execution.
 *
 * A task has at most one next execution. If the same task instance is scheduled multiple times, the
 * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and
 * those implied by the returned execution delay.

      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;

import org.codelibs.fess.unit.UnitFessTestCase;

public class JobNotFoundExceptionTest extends UnitFessTestCase {

    public void test_constructorWithScheduledJob() {
        // Test with scheduled job that has a custom toString implementation
        ScheduledJob scheduledJob = new ScheduledJob() {
            @Override
            public String toString() {
                return "TestScheduledJob[id=123]";

    /**
     * Constructs a new JobNotFoundException with a message derived from the scheduled job.
     *
     * @param scheduledJob the scheduled job that was not found
     */
    public JobNotFoundException(final ScheduledJob scheduledJob) {
        super(scheduledJob.toString());
    }

    /**
     * Constructs a new JobNotFoundException with the specified detail message.
     *

```
[2020-01-01 00:00:00] Q10000 scheduled after   0 µs: OkHttp ConnectionPool
[2020-01-01 00:00:00] Q10000 starting              : OkHttp ConnectionPool
[2020-01-01 00:00:00] Q10000 run again after 300 s : OkHttp ConnectionPool
[2020-01-01 00:00:00] Q10000 finished run in   1 ms: OkHttp ConnectionPool
[2020-01-01 00:00:00] Q10001 scheduled after   0 µs: OkHttp squareup.com applyAndAckSettings

          } catch (_: InterruptedException) {
            // Will cause all tasks to exit unless more are scheduled!
            cancelAll()
          } finally {
            coordinatorWaiting = false
          }
        }
      }
    }
  }

  /** Start another thread, unless a new thread is already scheduled to start. */
  private fun startAnotherThread() {
    assertLockHeld()

 */
package org.codelibs.fess.app.web.admin.scheduler;

import org.lastaflute.web.validation.Required;
import org.lastaflute.web.validation.theme.conversion.ValidateTypeFailure;

import jakarta.validation.constraints.Size;

/**
 * Form class for editing scheduled job configurations in the admin interface.
 * This form extends CreateForm to include fields necessary for updating existing scheduler entries,

 */
package org.codelibs.fess.app.web.admin.scheduler;

/**
 * The search form for Scheduler.
 */
public class SearchForm {

    /**
     * Default constructor for SearchForm.
     */
    public SearchForm() {
    }

    /**
     * The ID field for searching scheduled jobs.
     */
    public String id;

        String message = "Test scheduled job error";
        ScheduledJobException exception = new ScheduledJobException(message);

        assertEquals(message, exception.getMessage());
        assertNull(exception.getCause());
    }

    public void test_constructorWithMessageAndCause() {
        // Test constructor with message and cause
        String message = "Test scheduled job error with cause";

            totalCalls.incrementAndGet();
            // Make sure that no other tasks are scheduled to run while this is running.
            assertFalse(fakePool.hasNext());
          }
        };

    assertFalse(fakePool.hasNext());
    e.execute(intCounter);
    // A task should have been scheduled
    assertTrue(fakePool.hasNext());
    e.execute(intCounter);
    // Our executor hasn't run any tasks yet.