* either it has exceeded the keep alive limit or the idle connections limit.
   *
   * Returns the duration in nanoseconds to sleep until the next scheduled call to this method.
   * Returns -1 if no further cleanups are required.
   */
  fun closeConnections(now: Long): Long {
    // Find the longest-idle connections in 2 categories:
    //

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

import org.codelibs.fess.app.web.api.admin.BaseSearchBody;

/**
 * Search request body for scheduler administration API.
 */
public class SearchBody extends BaseSearchBody {

    /**
     * Default constructor.
     */
    public SearchBody() {
        super();
    }

    /** Scheduler ID */
    public String id;

        this.directoryCache = new ConcurrentHashMap<>();
        this.leaseToPath = new ConcurrentHashMap<>();
        this.scheduler = Executors.newScheduledThreadPool(1);
        this.changeNotifier = new DirectoryChangeNotifier(this);
        
        // Schedule periodic cache cleanup
        scheduler.scheduleAtFixedRate(this::cleanupExpiredEntries, 60, 60, TimeUnit.SECONDS);
    }
    

- Migrate `pkg/scheduler/framework/plugins/interpodaffinity/filtering.go`,`pkg/scheduler/framework/plugins/podtopologyspread/filtering.go`, `pkg/scheduler/framework/plugins/volumezone/volume_zone.go` to structured logging (#105931, @mengjiao-liu) [SIG Instrumentation and Scheduling]

        final AllJobScheduler scheduler = new AllJobScheduler();
        assertTrue(scheduler instanceof LaJobScheduler);
    }

    public void test_AllJobScheduler_creation() {
        final AllJobScheduler scheduler = new AllJobScheduler();
        assertNotNull(scheduler);
    }

    public void test_setJobClass() {
        final AllJobScheduler scheduler = new AllJobScheduler();

### Scheduling

    private final Path stateDirectory;
    private final ScheduledExecutorService scheduler;
    private final CIFSContext context;
    
    public PersistentHandleManager(CIFSContext context) {
        this.context = context;
        this.handles = new ConcurrentHashMap<>();
        this.guidToHandle = new ConcurrentHashMap<>();
        this.scheduler = Executors.newScheduledThreadPool(1);
        

import org.junit.jupiter.api.Test;

public class JobNotFoundExceptionTest extends UnitFessTestCase {

    @Test
    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]";

        while (count < 1500 && !isRunning) {
            ThreadUtil.sleep(sleepTime);
            count++;
            final Map<String, Object> scheduler = getSchedulerItem(namePrefix);
            assertTrue(scheduler.containsKey("running"));
            isRunning = (Boolean) scheduler.get("running");

            // Exponential backoff: gradually increase sleep time up to 300ms
            if (count % 5 == 0 && sleepTime < 300) {

# easily import the generated PRs into our internal repo.
#  - package-ecosystem: "maven"
#    directory: "/"
#    schedule:
#      interval: "weekly"
#    groups:
#      dependencies:
#        applies-to: version-updates
#        patterns:
#          - "*"
#  - package-ecosystem: "maven"
#    directory: "/android"
#    schedule:
#      interval: "weekly"
#    groups:
#      dependencies:
#        applies-to: version-updates