int priority = Thread.NORM_PRIORITY;
        webFsIndexHelper.setIndexUpdaterPriority(priority);
        assertEquals(priority, webFsIndexHelper.indexUpdaterPriority);
    }

    public void test_setCrawlerPriority() {
        int priority = Thread.NORM_PRIORITY;
        webFsIndexHelper.setCrawlerPriority(priority);
        assertEquals(priority, webFsIndexHelper.crawlerPriority);
    }

     *
     * @return the priority value
     */
    public int getPriority() {
        return priority;
    }

    /**
     * Sets the priority of this ingester.
     * Lower numbers indicate higher priority.
     *
     * @param priority the priority value to set
     */
    public void setPriority(final int priority) {
        this.priority = priority;
    }

    /**

  public ThreadFactoryBuilder setPriority(int priority) {
    // Thread#setPriority() already checks for validity. These error messages
    // are nicer though and will fail-fast.
    checkArgument(
        priority >= Thread.MIN_PRIORITY,
        "Thread priority (%s) must be >= %s",
        priority,
        Thread.MIN_PRIORITY);
    checkArgument(
        priority <= Thread.MAX_PRIORITY,

        newIngesters[ingesters.length] = ingester;
        Arrays.sort(newIngesters, (o1, o2) -> o1.priority - o2.priority);
        ingesters = newIngesters;
    }

    /**
     * Returns the array of registered ingesters sorted by priority.
     * The returned array contains all ingesters in priority order
     * (lower priority numbers first).
     *
     * @return the sorted array of ingesters
     */

        }
    }

    /**
     * Gets the priority of this score booster.
     * @return The priority.
     */
    public int getPriority() {
        return priority;
    }

    /**
     * Sets the priority of this score booster.
     * @param priority The priority.
     */
    public void setPriority(final int priority) {
        this.priority = priority;
    }

    /**

        }
    }

    // Test class with priority tracking
    private static class PriorityTrackingBooster extends ScoreBooster {
        private static List<Integer> executionOrder = new ArrayList<>();
        private final long returnValue;

        public PriorityTrackingBooster(int priority, long returnValue) {
            this.priority = priority;
            this.returnValue = returnValue;
        }

        int priority = Thread.NORM_PRIORITY; // Use normal priority for tests
        dataIndexHelper.setCrawlerPriority(priority);

        try {
            Field field = DataIndexHelper.class.getDeclaredField("crawlerPriority");
            field.setAccessible(true);
            int actualPriority = (Integer) field.get(dataIndexHelper);
            assertEquals(priority, actualPriority);

        this.crawlingExecutionInterval = crawlingExecutionInterval;
    }

    /**
     * Sets the thread priority for crawler threads.
     * This priority will be applied to all newly created crawler threads.
     *
     * @param crawlerPriority thread priority (typically Thread.MIN_PRIORITY to Thread.MAX_PRIORITY)
     */
    public void setCrawlerPriority(final int crawlerPriority) {

    }

    /**
     * Sets the thread priority for index updater operations.
     *
     * @param indexUpdaterPriority The index updater thread priority
     */
    public void setIndexUpdaterPriority(final int indexUpdaterPriority) {
        this.indexUpdaterPriority = indexUpdaterPriority;
    }

    /**
     * Sets the thread priority for crawler operations.
     *

/**
 * Benchmarks for {@link Monitor}.
 *
 * @author Justin T. Sampson
 */
@NullUnmarked
public class MonitorBenchmark {

  @Param({"10", "100", "1000"})
  int capacity;

  @Param({"Array", "Priority"})
  String queueType;

  @Param boolean useMonitor;

  private BlockingQueue<String> queue;
  private String[] strings;

  @BeforeExperiment
  @SuppressWarnings("unchecked")