}

  public void testSubmit_runnable_completesAfterRun() throws Exception {
    List<Runnable> pendingRunnables = new ArrayList<>();
    List<Runnable> executedRunnables = new ArrayList<>();
    Runnable runnable =
        new Runnable() {
          @Override
          public void run() {
            executedRunnables.add(this);
          }
        };

 *
 * @author Kurt Alfred Kluever
 * @author Martin Buchholz
 */
@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public class ThreadFactoryBuilderTest extends TestCase {
  private final Runnable monitoredRunnable = () -> completed = true;

  private static final UncaughtExceptionHandler UNCAUGHT_EXCEPTION_HANDLER =
      (thread, throwable) -> {};

  private ThreadFactoryBuilder builder;

    before.assertRun();
    inBetween.assertRun();
    after.assertRun();
  }

  public void testMisbehavingListenerAlreadyDone() {
    class BadRunnableException extends RuntimeException {}

    Runnable bad =
        () -> {
          throw new BadRunnableException();
        };

    future.set(1);
    future.addListener(bad, directExecutor()); // BadRunnableException must not propagate.
  }

   */
  @Override
  ListenableFuture<?> submit(Runnable task);

  /**
   * @return a {@code ListenableFuture} representing pending completion of the task
   * @throws RejectedExecutionException {@inheritDoc}
   */
  @Override
  <T extends @Nullable Object> ListenableFuture<T> submit(
      Runnable task, @ParametricNullness T result);

  /**
   * {@inheritDoc}
   *

    Logger.getLogger(AbstractFuture.class.getName()).addHandler(logHandler);

    List<Future<?>> results = new ArrayList<>();
    Runnable[] manualExecutorTask = new Runnable[1];
    Executor manualExecutor =
        new Executor() {
          @Override
          public void execute(Runnable task) {
            manualExecutorTask[0] = task;
          }
        };

 * execute}.
 */
@GwtCompatible
enum DirectExecutor implements Executor {
  INSTANCE;

  @Override
  public void execute(Runnable command) {
    command.run();
  }

  @Override
  public String toString() {
    return "MoreExecutors.directExecutor()";
  }

        // nothing
    }

    /**
     * Executes the given task in the common ForkJoinPool.
     *
     * @param task
     *            the task to execute
     */
    public static void execute(final Runnable task) {
        ForkJoinPool.commonPool().execute(() -> {
            final Thread currentThread = Thread.currentThread();
            final ClassLoader orignal = currentThread.getContextClassLoader();

 *
 * {@snippet :
 * final String name = ...;
 * inFlight.add(name);
 * ListenableFuture<Result> future = service.query(name);
 * future.addListener(new Runnable() {
 *   public void run() {
 *     processedCount.incrementAndGet();
 *     inFlight.remove(name);
 *     lastProcessed.set(name);
 *     logger.info("Done with {0}", name);
 *   }
 * }, executor);
 * }
 *

        assertEquals(currentTime, t.ltime, "ltime should be mutable");
    }

    @Test
    @DisplayName("TestLocking implements Runnable")
    void testImplementsRunnable() {
        TestLocking t = new TestLocking();
        assertTrue(t instanceof Runnable, "TestLocking should implement Runnable");
    }

    @Test
    @DisplayName("run method handles null URL gracefully")
    void testRunWithNullUrl() {

import org.jspecify.annotations.Nullable;

/** Emulation for InterruptibleTask in GWT. */
abstract class InterruptibleTask<T extends @Nullable Object> implements Runnable {

  @Override
  public void run() {
    T result = null;
    Throwable error = null;
    if (isDone()) {
      return;
    }
    try {
      result = runInterruptibly();
    } catch (Throwable t) {