Наращивание памяти при использовании CompletableFuture

class DataItemCache {
    private CompletableFuture future;

    public DataItemCache() {
        future = CompletableFuture.completedFuture(null);
    }

    public void saveItemAsync(Object dataItem) {
        future = future.thenRunAsync(() -> {
            saveItemSync(dataItem); // Saves the item to Elastic Search
        });
    }

    public void waitForWriteComplete() {
        future.get();
    }

Этот класс используется следующим образом:

class DataProcessorIntegrationTest {
    @Inject private DataItemCache dataItemCache;

    @Before
    public void setup() {
        // Setup Guice for injection
    }

    @Test
    public void testWorkflow() {
        int numItems = 1000;
        for (int index = 0; index < numItems; index++) {
            DataItem obj = ... // build data item
            dataItemCache.saveItemAsync(obj);
        }

        // I have code to periodically dump the heap during this wait

        dataItemCache.waitForWriteComplete();

        // assert that Elastic Search has 1000 items
    }
}

Количество элементов данных, выделенных непосредственно перед возвратом функции waitForWriteComplete(), равно 1000, а сразу после этого равно 0. Я ожидаю, что количество элементов данных будет меньше 1000, так как некоторые из них завершили запись в Elastic Search ( Я знаю это из журналов консоли).

Когда я запускаю этот код в производство, я получаю OOM. Проверка кучи во время OOM показывает миллионы объектов DataItem и CompletableFuture. Очевидно, что многие из них должны были завершить написание и вернуться из метода saveItem. Почему такие объекты DataItem и CompletableFuture не освобождаются?

Любые идеи о том, как решить эту проблему?