}

        // Test with config parameters
        configParameters = "config.timeout=30\nconfig.retry=3";
        result = ParameterUtil.createConfigParameterMap(configParameters);
        assertEquals(2, result.get(ConfigName.CONFIG).size());
        assertEquals("30", result.get(ConfigName.CONFIG).get("timeout"));
        assertEquals("3", result.get(ConfigName.CONFIG).get("retry"));

    }

    @Test
    public void test_parseTime_validFormat() {
        int[] result = IntervalControlHelper.parseTime("12:30");
        assertEquals(12, result[0]);
        assertEquals(30, result[1]);

        result = IntervalControlHelper.parseTime("00:00");
        assertEquals(0, result[0]);
        assertEquals(0, result[1]);

        result = IntervalControlHelper.parseTime("23:59");

    assertEquals(20, counter.getCount());
  }

  public void testReadArrayEOF() throws IOException {
    assertEquals(20, counter.read(new byte[30]));
    assertEquals(20, counter.getCount());
    assertEquals(-1, counter.read(new byte[30]));
    assertEquals(20, counter.getCount());
  }

  @SuppressWarnings("CheckReturnValue") // calling read() to skip a byte
  public void testMark() throws Exception {

		for par := 1; par <= 32; par *= 2 {
			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
				defer timeout(60 * time.Second)()
				ctx, cancel := context.WithTimeout(b.Context(), 30*time.Second)
				defer cancel()
				b.ReportAllocs()
				b.SetBytes(int64(len(payload) * 2))
				b.ResetTimer()
				t := time.Now()
				var ops int64
				var lat int64
				b.SetParallelism(par)

        docList.addContentSize(100);
        assertEquals(100, docList.getContentSize());

        docList.addContentSize(-30);
        assertEquals(70, docList.getContentSize());

        docList.addContentSize(-100);
        assertEquals(-30, docList.getContentSize());
    }

    @Test
    public void test_addProcessingTime_negative() {
        DocList docList = new DocList();

    assertThat(cache.getIfPresent(2)).isEqualTo(20);
    assertThat(cache.getIfPresent(3)).isEqualTo(30);
    assertThat(cache.getIfPresent(4)).isEqualTo(40);
    assertThat(cache.getIfPresent(5)).isEqualTo(50);

    cache.put(1, 10);
    assertThat(cache.getIfPresent(1)).isEqualTo(10);
    assertThat(cache.getIfPresent(3)).isEqualTo(30);
    assertThat(cache.getIfPresent(4)).isEqualTo(40);

                return expectedTime[0];
            }
        };

        FessConfig fessConfig = new TestFessConfig() {
            @Override
            public int getPurgeSearchLogDay() {
                return 30;
            }

            @Override
            public int getPurgeJobLogDay() {
                return 14;
            }

            @Override
            public int getPurgeUserInfoDay() {

                }
            });
        }

        // Start all threads simultaneously
        startLatch.countDown();

        // Wait for completion
        assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete within timeout");
        executor.shutdown();

        // Then - Verify no exceptions occurred
        if (!exceptions.isEmpty()) {

          #Comma separated list of labels that can be assigned to PRs to exclude them from being marked as stale
          exempt-pr-labels: "override-stale"
          #Limit the No. of API calls in one run default value is 30.
          operations-per-run: 1000
          days-before-issue-stale: 7
          days-before-issue-close: 7
          stale-issue-label: "stale"
          # reason for closed the issue default value is not_planned

    /**
     * Default constructor for PurgeThumbnailJob.
     * Creates a new instance of the thumbnail purging job with default expiry time (30 days).
     */
    public PurgeThumbnailJob() {
        // Default constructor
    }

    /** Expiration time for thumbnails in milliseconds (default: 30 days) */
    private long expiry = 30 * 24 * 60 * 60 * 1000L;

    /**
     * Executes the thumbnail purging job.