graph.putEdgeValue(5, 6, "C");

    int threadCount = 20;
    ExecutorService executor = newFixedThreadPool(threadCount);
    CyclicBarrier barrier = new CyclicBarrier(threadCount);
    ImmutableList.Builder<Future<?>> futures = ImmutableList.builder();
    for (int i = 0; i < threadCount; i++) {
      futures.add(
          executor.submit(
              () -> {
                barrier.await();

import com.google.errorprone.annotations.CanIgnoreReturnValue;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.locks.AbstractQueuedSynchronizer;
import org.jspecify.annotations.NullUnmarked;

=== ":material-language-kotlin: Kotlin"
    ```kotlin
      private val executor = Executors.newScheduledThreadPool(1)
      private val client = OkHttpClient()

      fun run() {
        val request = Request.Builder()

 * <li>{@link #analyzer} - Suggest analyzer.</li>
 * <li>{@link #contentsParser} - Contents parser.</li>
 * <li>{@link #suggestWriter} - Suggest writer.</li>
 * <li>{@link #threadPool} - Executor service for thread pool.</li>
 * </ul>
 */
public class SuggestIndexer {
    private final static Logger logger = LogManager.getLogger(SuggestIndexer.class);

    /** The suggest analyzer. */

    private final boolean parallel;

    /**
     * Constructor.
     *
     * @param client The OpenSearch client
     * @param settings The suggest settings
     * @param threadPool The executor service for async operations
     * @param indexingOps The indexing operations for writing items
     * @param contentsParser The contents parser for parsing documents
     * @param analyzer The suggest analyzer

public class ChannelFailover {
    private final ChannelManager manager;
    private final ExecutorService executor;
    private final Map<String, FailoverState> failoverStates;
    
    public ChannelFailover(ChannelManager manager) {
        this.manager = manager;
        this.executor = Executors.newCachedThreadPool();
        this.failoverStates = new ConcurrentHashMap<>();
    }
    

     */
    requireNonNull(futures);

    // Corner case: List is empty.
    if (futures.isEmpty()) {
      handleAllCompleted();
      return;
    }

    // NOTE: If we ever want to use a custom executor here, have a look at CombinedFuture as we'll
    // need to handle RejectedExecutionException

    if (allMustSucceed) {
      // We need fail fast, so we have to keep track of which future failed so we can propagate

        String result = pythonJob.execute();

        assertTrue(result.contains("Session Id:"));
        assertTrue(result.contains("Python Process terminated."));
    }

    // Test execute with job executor
    @Test
    public void test_execute_withJobExecutor() {
        pythonJob.filename("test.py");

        TestJobExecutor jobExecutor = new TestJobExecutor();
        pythonJob.jobExecutor = jobExecutor;

        SmbTransportPoolImpl pool = new SmbTransportPoolImpl();
        pool.setMaxPoolSize(100);

        int threadCount = 20;
        int operationsPerThread = 100;
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);
        CountDownLatch startLatch = new CountDownLatch(1);
        CountDownLatch endLatch = new CountDownLatch(threadCount);

        AtomicLong totalTime = new AtomicLong(0);

        assertTrue(result.contains("Session Id: " + existingSessionId));
        assertEquals(existingSessionId, suggestJob.sessionId);
    }

    // Test execute method with job executor shutdown listener
    @Test
    public void test_execute_withJobExecutor() {
        createRequiredDirectories();
        MockJobExecutor mockJobExecutor = new MockJobExecutor();