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);

    // Explicit replacements take priority over unsafe characters.
    builder.addEscape(' ', "_");
    builder.addEscape('!', "_");
    assertThat(builder.build().escape("The Quick Brown Fox!")).isEqualTo("Xhe_Xuick_Xrown_Xox_");
    // Explicit replacements take priority over safe characters.
    builder.setSafeRange(' ', '~');

        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.
     *

    )

    /**
     * Called when reading a headers or priority frame. This may be used to change the stream's
     * weight from the default (16) to a new value.
     *
     * @param streamId stream which has a priority change.
     * @param streamDependency the stream ID this stream is dependent on.
     * @param weight relative proportion of priority in `[1..256]`.

Package: fess
Version: [[version]]
Architecture: all
Maintainer: Fess Team
Depends: libc6, adduser
Section: web
Priority: optional
Homepage: https://github.com/codelibs/fess
Description: Enterprise Search Server: Fess

    debugData: ByteString,
  ) {
    fail("")
  }

  override fun windowUpdate(
    streamId: Int,
    windowSizeIncrement: Long,
  ) {
    fail("")
  }

  override fun priority(
    streamId: Int,
    streamDependency: Int,
    weight: Int,
    exclusive: Boolean,
  ) {
    fail("")
  }

  override fun pushPromise(
    streamId: Int,
    associatedStreamId: Int,

/**
 * 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")

     *
     * @param <E> the element type of {@link PriorityBlockingQueue}
     * @param initialCapacity the initial capacity of the priority queue
     * @param comparator the comparator for ordering the elements in the priority queue
     * @return a new instance of {@link PriorityBlockingQueue}
     * @see PriorityBlockingQueue#PriorityBlockingQueue(int, Comparator)
     */

   * Returns the {@link Executor} that will be used to run this service. Subclasses may override
   * this method to use a custom {@link Executor}, which may configure its worker thread with a
   * specific name, thread group or priority. The returned executor's {@link
   * Executor#execute(Runnable) execute()} method is called when this service is started, and should
   * return promptly.
   *