return task;
  }

  /**
   * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that
   * will complete after execution.
   *
   * @throws RejectedExecutionException if the task cannot be scheduled for execution
   * @since 28.2
   */
  public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
    TrustedListenableFutureTask<@Nullable Void> task =

            Map<String, MavenProject> reactorGavs =
                    projects.keySet().stream().collect(Collectors.toMap(BuildPlanExecutor::gav, p -> p));

            // Go through all plugins
            List<Runnable> toResolve = new ArrayList<>();
            projects.keySet().forEach(project -> project.getBuild().getPlugins().forEach(plugin -> {
                MavenProject pluginProject = reactorGavs.get(gav(plugin));

	public final fun getIdleCallback ()Ljava/lang/Runnable;
	public final fun getMaxRequests ()I
	public final fun getMaxRequestsPerHost ()I
	public final fun queuedCalls ()Ljava/util/List;
	public final fun queuedCallsCount ()I
	public final fun runningCalls ()Ljava/util/List;
	public final fun runningCallsCount ()I
	public final fun setIdleCallback (Ljava/lang/Runnable;)V
	public final fun setMaxRequests (I)V

    val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost
    dispatcher.maxRequestsPerHost = 0
    val executorService: ExecutorService = dispatcher.executorService
    dispatcher.idleCallback = Runnable { TODO() }
    val queuedCalls: List<Call> = dispatcher.queuedCalls()
    val runningCalls: List<Call> = dispatcher.runningCalls()
    val queuedCallsCount: Int = dispatcher.queuedCallsCount()

	public final fun getIdleCallback ()Ljava/lang/Runnable;
	public final fun getMaxRequests ()I
	public final fun getMaxRequestsPerHost ()I
	public final fun queuedCalls ()Ljava/util/List;
	public final fun queuedCallsCount ()I
	public final fun runningCalls ()Ljava/util/List;
	public final fun runningCallsCount ()I
	public final fun setIdleCallback (Ljava/lang/Runnable;)V
	public final fun setMaxRequests (I)V

    sink.writeUtf8(bytes)
    sink.close()
    return bytesOut
  }

  internal inner class AsyncRequest(
    val path: String,
    val countDownLatch: CountDownLatch,
  ) : Runnable {
    override fun run() {
      try {
        val call =
          client.newCall(
            Request
              .Builder()
              .url(server.url(path))
              .build(),

    }

    @Override
    void maybeClearReferenceQueues() {
      clearReferenceQueue(queueForKeys);
    }
  }

  static final class CleanupMapTask implements Runnable {
    final WeakReference<MapMakerInternalMap<?, ?, ?, ?>> mapReference;

    public CleanupMapTask(MapMakerInternalMap<?, ?, ?, ?> map) {
      this.mapReference = new WeakReference<>(map);
    }

    }

    @Override
    void maybeClearReferenceQueues() {
      clearReferenceQueue(queueForKeys);
    }
  }

  static final class CleanupMapTask implements Runnable {
    final WeakReference<MapMakerInternalMap<?, ?, ?, ?>> mapReference;

    public CleanupMapTask(MapMakerInternalMap<?, ?, ?, ?> map) {
      this.mapReference = new WeakReference<>(map);
    }