private ServerSocket makeMyServerExampleWithFrq(AtomicBoolean finalizeReferentRan)
      throws IOException {
    MyServerExampleWithFrq myServer = MyServerExampleWithFrq.create(finalizeReferentRan);
    assertThat(myServer.serverSocket.isClosed()).isFalse();
    return myServer.serverSocket;
  }

  @Test
  public void testMyServerExampleWithFrq() throws Exception {
    AtomicBoolean finalizeReferentRan = new AtomicBoolean(false);

  class Interruptenator extends Thread {
    final AtomicBoolean shutdown;

    Interruptenator(Thread interruptee) {
      this(interruptee, new AtomicBoolean(false));
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    Interruptenator(Thread interruptee, AtomicBoolean shutdown) {
      super(
          new Runnable() {
            @Override

     */
    public void test_MsWordExtractor_closesResourcesOnSuccess() throws IOException {
        final MsWordExtractor extractor = container.getComponent("msWordExtractor");
        final AtomicBoolean streamClosed = new AtomicBoolean(false);

        try (final InputStream originalStream = ResourceUtil.getResourceAsStream("extractor/msoffice/test.doc")) {

  class Interruptenator extends Thread {
    final AtomicBoolean shutdown;

    Interruptenator(Thread interruptee) {
      this(interruptee, new AtomicBoolean(false));
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    Interruptenator(Thread interruptee, AtomicBoolean shutdown) {
      super(
          new Runnable() {
            @Override

    AtomicReference<AbstractFuture<String>> setFutureFuture = Atomics.newReference();
    AtomicBoolean setFutureSetSuccess = new AtomicBoolean();
    AtomicBoolean setFutureCompletionSuccess = new AtomicBoolean();
    AtomicBoolean cancellationSuccess = new AtomicBoolean();
    Runnable cancelRunnable =
        new Runnable() {
          @Override
          public void run() {

    AtomicReference<AbstractFuture<String>> setFutureFuture = Atomics.newReference();
    AtomicBoolean setFutureSetSuccess = new AtomicBoolean();
    AtomicBoolean setFutureCompletionSuccess = new AtomicBoolean();
    AtomicBoolean cancellationSuccess = new AtomicBoolean();
    Runnable cancelRunnable =
        new Runnable() {
          @Override
          public void run() {

    /** Queue of documents. */
    protected final Queue<Map<String, Object>> queue = new ConcurrentLinkedQueue<>();
    /** Flag indicating if reading is finished. */
    protected final AtomicBoolean isFinished = new AtomicBoolean(false);

    /** OpenSearch client. */
    protected final Client client;
    /** Suggest settings. */
    protected final SuggestSettings settings;
    /** Index name. */

    when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS))
        .thenThrow(new InterruptedException());

    AtomicBoolean terminated = new AtomicBoolean();
    // we need to keep this in a flag because t.isInterrupted() returns false after t.join()
    AtomicBoolean interrupted = new AtomicBoolean();
    // we need to use another thread because it will be interrupted and thus using

        assertFalse(component.isDestroyed());
    }

    /**
     * Test destroyObject with listener
     */
    public void test_destroyObject_withListener() throws Exception {
        AtomicBoolean listenerCalled = new AtomicBoolean(false);
        final PooledObject<TestComponent>[] capturedObject = new PooledObject[1];

        OnDestroyListener<TestComponent> listener = new OnDestroyListener<TestComponent>() {

    /** Helper for managing content length limits */
    @Resource
    protected ContentLengthHelper contentLengthHelper;

    /** Flag to track initialization status */
    protected AtomicBoolean isInit = new AtomicBoolean(false);

    /**
     * Constructs a new FileSystemClient.
     */
    public FileSystemClient() {
        // Default constructor
    }

    /*
     * (non-Javadoc)
     *