}

    public void test_setIndexUpdaterPriority() {
        int priority = Thread.MAX_PRIORITY;
        webFsIndexHelper.setIndexUpdaterPriority(priority);
        assertEquals(priority, webFsIndexHelper.indexUpdaterPriority);
    }

    public void test_setIndexUpdaterPriority_withMinValue() {
        int priority = Thread.MIN_PRIORITY;
        webFsIndexHelper.setIndexUpdaterPriority(priority);

              @Override
              public Integer call() {
                return Thread.currentThread().getStackTrace().length;
              }
            },
            directExecutor());
    settableFuture.set(null);
    assertThat(getDone(stackDepthCheck))
        .isLessThan(Thread.currentThread().getStackTrace().length + 100);
  }

        // Trip circuit
        circuitBreaker.trip();
        Thread.sleep(100);

        long afterTripTime = circuitBreaker.getTimeSinceLastStateChange();
        assertTrue(afterTripTime >= 100, "Time should have advanced");
        assertTrue(afterTripTime < 200, "Time should be reasonable");

        // Reset circuit
        circuitBreaker.reset();
        Thread.sleep(50);

                    }
                });
            }

            // Start all threads
            for (Thread t : threads) {
                t.start();
            }

            // Wait for completion
            for (Thread t : threads) {
                t.join();
            }

            // Verify thread safety - no unexpected exceptions

import jakarta.annotation.Resource;

/**
 * The {@code CrawlerThread} class represents a thread that executes the crawling process.
 * It is responsible for fetching URLs from the queue, accessing the content,
 * processing the response, and extracting child URLs.
 *
 * <p>
 * This class implements the {@link Runnable} interface, allowing it to be executed in a separate thread.

    }

    /**
     * Sets the thread pool.
     * @param threadPool The thread pool.
     * @return This builder instance.
     */
    public SuggesterBuilder threadPool(final ExecutorService threadPool) {
        this.threadPool = threadPool;
        return this;
    }

    /**
     * Sets the thread pool size.
     * @param threadPoolSize The thread pool size.
     * @return This builder instance.

     */
    public void setTimeout(final long timeout) {
        this.timeout = timeout;
    }

    /**
     * Sets whether the extraction thread should be a daemon thread.
     * @param isDaemonThread true to make it a daemon thread, false otherwise.
     */
    public void setDaemonThread(final boolean isDaemonThread) {
        this.isDaemonThread = isDaemonThread;
    }

 * This class provides access to the underlying process and manages
 * the input stream thread for capturing process output.
 */
public class JobProcess {
    /**
     * The underlying system process.
     */
    protected Process process;

    /**
     * The thread that handles reading from the process input stream.
     */
    protected InputStreamThread inputStreamThread;

    /**

  /**
   * Returns an exception handler that exits the system. This is particularly useful for the main
   * thread, which may start up other, non-daemon threads, but fail to fully initialize the
   * application successfully.
   *
   * <p>Example usage:
   *
   * <pre>
   * public static void main(String[] args) {
   *   Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit());
   *   ...
   * </pre>
   *

    /**
     * Processes finished thread log events.
     *
     * @param objs the log objects
     */
    protected void processFinishedThread(final Object... objs) {
        // CrawlerContext crawlerContext = (CrawlerContext) objs[0];
    }

    /**
     * Processes no URL in queue log events.
     *
     * @param objs the log objects (should contain UrlQueue and thread check count)
     */