← Todas las estructuras

Dynamic Array

Linear · ver código fuente en GitHub

Leer en: English · Português · Español

Categoría: Linear

El problema

Un array común de Java tiene tamaño fijo desde su creación. La mayoría de los casos de uso reales no conoce el tamaño final de antemano — los registros llegan uno a la vez desde un archivo, una cola, una solicitud. Asignar capacidad "suficiente" implica o bien sobreestimar (memoria desperdiciada) o subestimar (un desbordamiento que hay que manejar a mano: asignar un array más grande, copiar cada elemento, y seguir).

La solución

Envuelve un array crudo y hazlo crecer automáticamente: cuando un add desbordaría el array subyacente, asigna un nuevo array con el doble de capacidad, copia todo hacia él, y sigue agregando. Un único redimensionamiento es O(n), pero ocurre exponencialmente con menos frecuencia a medida que el array crece, así que el costo promedio por add a lo largo de muchos appends — el costo amortizado — se mantiene en O(1). La reducción refleja esta misma lógica: cuando la ocupación cae a un cuarto de la capacidad, se reduce a la mitad, para que una carga de trabajo de llenar-y-vaciar no oscile redimensionando en cada remoción cerca de uno de esos límites.

flowchart LR
    A["size == capacity"] -->|add| B["allocate 2x array"]
    B --> C["copy n elements"]
    C --> D["append succeeds"]
    E["size == capacity/4"] -->|remove| F["allocate capacity/2 array"]
    F --> G["copy n elements"]
    G --> H["remove succeeds"]
Operación Costo Por qué
get(index) / set(index, v) O(1) desplazamiento directo en el array
add(v) (append) O(1) amortizado duplicar la capacidad mantiene la frecuencia de redimensionamiento exponencialmente pequeña
remove(index) O(n) desplaza cada elemento después de index una posición a la izquierda
iteración O(n) recorrido contiguo, favorable a la caché

Ejemplo clásico

classic/DynamicArray está construido sobre un Object[] crudo, no sobre java.util.ArrayListadd, get, set, remove e Iterable<T> están todos implementados a mano, incluyendo la política de crecimiento por duplicación y reducción por cuarto. DynamicArrayTest cubre el crecimiento más allá de la capacidad inicial, la reducción tras vaciarse, el acceso fuera de límites, y el agotamiento del iterador.

Ejemplo aplicado: búfer de registros por lotes

applied/BatchRecordBuffer almacena temporalmente filas de PolicyBatchRecord a medida que llegan desde una extracción por lotes de primas de seguro, y luego las distribuye a workers paralelos en bloques de tamaño fijo mediante drainInChunksOf. Es exactamente la forma que enfrenta un pipeline de lotes a gran escala (3M+ filas/día en una gran aseguradora): la ingesta es puro append, y el vaciado es un único recorrido masivo — el diseño contiguo de un array dinámico sirve mejor a ambos casos que lo haría una linked list. BatchRecordBufferTest cubre límites de bloques pares/impares y el caso de búfer vacío.

Benchmark

./gradlew :linear:dynamic-array:jmh

Ejecución real en esta máquina (JMH 1.37, JDK 26.0.2, 2 iteraciones de warmup + 3 de medición, 1 fork):

Benchmark size=100 size=10,000 size=1,000,000
append (total para N appends) 611 ns 75,047 ns 75.6 ms
get (lectura indexada única) 2.50 ns 2.44 ns 2.46 ns

get se mantiene estable en ~2.4–2.5 ns sin importar el tamaño — la afirmación de O(1), falsable y confirmada. El costo total de append escala de forma aproximadamente lineal con el tamaño (≈6–7.5 ns/elemento en 100 y 10,000), que es lo que se ve como "O(1) amortizado por elemento" cuando se observa en conjunto; la fila de 1,000,000 tuvo una iteración que coincidió con un redimensionamiento grande y sesgó el promedio hacia arriba, lo cual es el resultado honesto y sin suavizar de que un redimensionamiento de array por duplicación efectivamente ocurrió a mitad del benchmark, no un error de medición.

Cuándo no usarlo

Cobertura de pruebas

100% de cobertura de instrucciones, 100% de cobertura de ramas (JaCoCo). Reprodúcelo tú mismo:

./gradlew :linear:dynamic-array:jacocoTestReport

Informe en linear/dynamic-array/build/reports/jacoco/test/html/index.html.

Pruebas unitarias

src/test/java/com/datastructures/linear/dynamicarray/classic/DynamicArrayTest.java
package com.datastructures.linear.dynamicarray.classic;

import org.junit.jupiter.api.Test;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.NoSuchElementException;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;

class DynamicArrayTest {

    @Test
    void startsEmpty() {
        DynamicArray<String> array = new DynamicArray<>();

        assertThat(array.isEmpty()).isTrue();
        assertThat(array.size()).isZero();
    }

    @Test
    void addAppendsAndGetReadsBackInOrder() {
        DynamicArray<String> array = new DynamicArray<>();

        array.add("a");
        array.add("b");
        array.add("c");

        assertThat(array.size()).isEqualTo(3);
        assertThat(array.get(0)).isEqualTo("a");
        assertThat(array.get(1)).isEqualTo("b");
        assertThat(array.get(2)).isEqualTo("c");
    }

    @Test
    void growsPastInitialCapacityWithoutLosingElements() {
        DynamicArray<Integer> array = new DynamicArray<>(2);

        for (int i = 0; i < 100; i++) {
            array.add(i);
        }

        assertThat(array.size()).isEqualTo(100);
        assertThat(array.capacity()).isGreaterThan(2);
        for (int i = 0; i < 100; i++) {
            assertThat(array.get(i)).isEqualTo(i);
        }
    }

    @Test
    void setReplacesElementAndReturnsThePreviousOne() {
        DynamicArray<String> array = new DynamicArray<>();
        array.add("original");

        String previous = array.set(0, "replaced");

        assertThat(previous).isEqualTo("original");
        assertThat(array.get(0)).isEqualTo("replaced");
    }

    @Test
    void removeShiftsSubsequentElementsLeft() {
        DynamicArray<String> array = new DynamicArray<>();
        array.add("a");
        array.add("b");
        array.add("c");

        String removed = array.remove(0);

        assertThat(removed).isEqualTo("a");
        assertThat(array.size()).isEqualTo(2);
        assertThat(array.get(0)).isEqualTo("b");
        assertThat(array.get(1)).isEqualTo("c");
    }

    @Test
    void shrinksCapacityAfterDrainingBelowAQuarterFull() {
        DynamicArray<Integer> array = new DynamicArray<>();
        for (int i = 0; i < 1000; i++) {
            array.add(i);
        }
        int grownCapacity = array.capacity();

        for (int i = 999; i >= 20; i--) {
            array.remove(i);
        }

        assertThat(array.capacity()).isLessThan(grownCapacity);
        for (int i = 0; i < array.size(); i++) {
            assertThat(array.get(i)).isEqualTo(i);
        }
    }

    @Test
    void getAndSetAndRemoveRejectOutOfBoundsIndexes() {
        DynamicArray<String> array = new DynamicArray<>();
        array.add("only");

        assertThatThrownBy(() -> array.get(-1)).isInstanceOf(IndexOutOfBoundsException.class);
        assertThatThrownBy(() -> array.get(1)).isInstanceOf(IndexOutOfBoundsException.class);
        assertThatThrownBy(() -> array.set(5, "x")).isInstanceOf(IndexOutOfBoundsException.class);
        assertThatThrownBy(() -> array.remove(5)).isInstanceOf(IndexOutOfBoundsException.class);
    }

    @Test
    void iteratesInInsertionOrderAndExhaustsCorrectly() {
        DynamicArray<Integer> array = new DynamicArray<>();
        array.add(1);
        array.add(2);
        array.add(3);

        List<Integer> collected = new ArrayList<>();
        for (int value : array) {
            collected.add(value);
        }

        assertThat(collected).containsExactly(1, 2, 3);
    }

    @Test
    void constructorRejectsNonPositiveInitialCapacity() {
        assertThatThrownBy(() -> new DynamicArray<Integer>(0)).isInstanceOf(IllegalArgumentException.class);
    }

    @Test
    void isEmptyReportsFalseOnceAnElementHasBeenAdded() {
        DynamicArray<String> array = new DynamicArray<>();

        array.add("a");

        assertThat(array.isEmpty()).isFalse();
    }

    @Test
    void iteratorNextThrowsOnceExhausted() {
        DynamicArray<Integer> array = new DynamicArray<>();
        array.add(1);
        Iterator<Integer> iterator = array.iterator();
        iterator.next();

        assertThatThrownBy(iterator::next).isInstanceOf(NoSuchElementException.class);
    }
}
src/test/java/com/datastructures/linear/dynamicarray/applied/BatchRecordBufferTest.java
package com.datastructures.linear.dynamicarray.applied;

import org.junit.jupiter.api.Test;

import java.math.BigDecimal;
import java.time.Instant;
import java.util.ArrayList;
import java.util.List;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;

class BatchRecordBufferTest {

    @Test
    void drainInChunksOfSplitsRecordsIntoFixedSizeChunksWithASmallerLastChunk() {
        BatchRecordBuffer buffer = new BatchRecordBuffer();
        for (int i = 0; i < 25; i++) {
            buffer.ingest(record("policy-" + i));
        }

        List<List<PolicyBatchRecord>> chunks = new ArrayList<>();
        buffer.drainInChunksOf(10, chunks::add);

        assertThat(chunks).hasSize(3);
        assertThat(chunks.get(0)).hasSize(10);
        assertThat(chunks.get(1)).hasSize(10);
        assertThat(chunks.get(2)).hasSize(5);
        assertThat(chunks.get(0).get(0).policyId()).isEqualTo("policy-0");
        assertThat(chunks.get(2).get(4).policyId()).isEqualTo("policy-24");
    }

    @Test
    void drainInChunksOfProducesExactlyOneFullChunkWhenSizeDividesEvenly() {
        BatchRecordBuffer buffer = new BatchRecordBuffer();
        buffer.ingest(record("policy-a"));
        buffer.ingest(record("policy-b"));

        List<List<PolicyBatchRecord>> chunks = new ArrayList<>();
        buffer.drainInChunksOf(2, chunks::add);

        assertThat(chunks).hasSize(1);
        assertThat(chunks.get(0)).hasSize(2);
    }

    @Test
    void drainClearsTheBufferAfterwards() {
        BatchRecordBuffer buffer = new BatchRecordBuffer();
        buffer.ingest(record("policy-a"));
        buffer.ingest(record("policy-b"));

        buffer.drainInChunksOf(10, chunk -> { });

        assertThat(buffer.size()).isZero();
    }

    @Test
    void drainOnAnEmptyBufferInvokesNoChunks() {
        BatchRecordBuffer buffer = new BatchRecordBuffer();

        List<List<PolicyBatchRecord>> chunks = new ArrayList<>();
        buffer.drainInChunksOf(10, chunks::add);

        assertThat(chunks).isEmpty();
    }

    @Test
    void drainInChunksOfRejectsANonPositiveChunkSize() {
        BatchRecordBuffer buffer = new BatchRecordBuffer();

        assertThatThrownBy(() -> buffer.drainInChunksOf(0, chunk -> { }))
                .isInstanceOf(IllegalArgumentException.class);
    }

    private static PolicyBatchRecord record(String policyId) {
        return new PolicyBatchRecord(policyId, BigDecimal.valueOf(199.90), Instant.now());
    }
}

Ver informe completo de cobertura JaCoCo →