diff --git a/CHANGELOG.md b/CHANGELOG.md index a31f0f9..6a2e4bd 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -2,6 +2,10 @@ ## [Unreleased] +### Bug fixes + +- Fix a memory leak due to the use of a local thread pool + ### Spring-data - Add `tarantool-spring-data-35` module with support for Spring Boot 3.5.x and Spring Data 3.5 diff --git a/testcontainers/src/main/java/org/testcontainers/containers/tqe/TQEClusterImpl.java b/testcontainers/src/main/java/org/testcontainers/containers/tqe/TQEClusterImpl.java index 58484a0..f7607ad 100644 --- a/testcontainers/src/main/java/org/testcontainers/containers/tqe/TQEClusterImpl.java +++ b/testcontainers/src/main/java/org/testcontainers/containers/tqe/TQEClusterImpl.java @@ -10,8 +10,6 @@ import java.util.Map; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CopyOnWriteArrayList; -import java.util.concurrent.Executor; -import java.util.concurrent.Executors; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -71,8 +69,6 @@ public synchronized void stop() { private static void startParallel( Map containers, TQEConfigurator configurator) { - - final Executor executor = Executors.newFixedThreadPool(containers.size()); final List> futures = new ArrayList<>(containers.size()); final CopyOnWriteArrayList errors = new CopyOnWriteArrayList<>(); @@ -87,8 +83,7 @@ private static void startParallel( LOGGER.error("Error starting TQE container [container_name='{}']", name, e); errors.add(e); } - }, - executor))); + }))); CompletableFuture.allOf(futures.toArray(new CompletableFuture[] {})).join();