} finally {
            if (task != null) {
                task.cancel();
            }
            if (p != null && p.isAlive()) {
                logger.warn("Process {} is still alive in finally block. Forcing destruction.", p);
                if (task == null) {
                    task = new ProcessDestroyer(p, ist, commandDestroyTimeout);

            this.creationTime = System.currentTimeMillis();
            this.allocationStackTrace = Thread.currentThread().getStackTrace();
            this.closed = false;
        }

        boolean isAlive() {
            return resourceRef.get() != null && !closed;
        }

        long getAge() {
            return System.currentTimeMillis() - creationTime;
        }
    }

    private ResourceManager() {

        indexUpdater.indexingHelper = indexingHelper;
    }

    @Override
    public void tearDown() throws Exception {
        if (indexUpdater != null && indexUpdater.isAlive()) {
            indexUpdater.setFinishCrawling(true);
            indexUpdater.interrupt();
            indexUpdater.join(1000);
        }
        super.tearDown();
    }

    // Test initialization

            interruptingThread.interrupt();
            joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
            Thread.interrupted();
            if (interruptingThread.isAlive()) {
              // This will be hidden by test-output redirection:
              logger.severe("InterruptenatorTask did not exit; future tests may be affected");
              /*

            interruptingThread.interrupt();
            joinUninterruptibly(interruptingThread, 2500, MILLISECONDS);
            Thread.interrupted();
            if (interruptingThread.isAlive()) {
              // This will be hidden by test-output redirection:
              logger.severe("InterruptenatorTask did not exit; future tests may be affected");
              /*

      this.shutdown = shutdown;
      start();
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    void shutdown() {
      shutdown.set(true);
      while (this.isAlive()) {
        Thread.yield();
      }
    }
  }

  void assertWrapsInterruptedException(RuntimeException e) {
    assertThat(e).hasMessageThat().contains("Unexpected interrupt");

        InputStreamThread thread = jobProcess.getInputStreamThread();

        assertEquals("InputStreamThread", thread.getName());
        assertFalse("Thread should not be started yet", thread.isAlive());
    }

    public void test_processAssignment() throws IOException {
        Process mockProcess = createMockProcess("assignment test");
        JobProcess jobProcess = new JobProcess(mockProcess);

      this.shutdown = shutdown;
      start();
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    void shutdown() {
      shutdown.set(true);
      while (this.isAlive()) {
        Thread.yield();
      }
    }
  }

  void assertWrapsInterruptedException(RuntimeException e) {
    assertThat(e).hasMessageThat().contains("Unexpected interrupt");

        }
        t.interrupt();
        if (logger.isDebugEnabled()) {
            logger.debug("TimeoutManager stopped.");
        }
        t.join(timeoutMillis);
        return !t.isAlive();
    }

    /**
     * Clears the managed {@link TimeoutTask}.
     */
    public synchronized void clear() {
        timeoutTaskList.clear();
    }

    /**

        // Stop the thread by sending n = -1
        synchronized (w) {
            w.write(new byte[0], -1, out);
        }

        w.join(2000);
        assertFalse(w.isAlive(), "WriterThread should stop after -1 sentinel");
    }

    @Test
    @DisplayName("WriterThread surfaces SmbException via checkException")
    void writerThread_propagates_exception() throws Exception {