Netty PooledDirect ByteBuf и ArrayList неожиданное поведение

Question

Это кажется глупой ошибкой, так как я не мог найти, почему не все записи были удалены. Я бегу с JAVA_OPTS:

-XX: MaxDirectMemorySize = 67108864 -Dio.netty.leakDetectionLevel = расширенный -D-Dio.netty.allocator.type= объединенный в пул -XX:+UseG1GC -Xms40m -Xmx40m -Dio.netty.allocator.numDirectArenas=4

Вот полный код:

private ByteBufAllocator alloc = PooledByteBufAllocator.DEFAULT;

//Configure the arena
//java -Dio.netty.allocator.numDirectArenas=... -Dio.netty.allocator.numHeapArenas=... 
public ByteBuf createObject(int size){
    return alloc.directBuffer(size);
}

public static void main(String[] args) throws InterruptedException {
    ArrayList<ByteBuf> arr = new ArrayList<>();
    try {
        DiameterLoggingConfiguration.initLogger();

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    ByufferTest bt = new ByufferTest();
    //Total of 66060288 ~ slightly less than 64 mb of direct memory
    for(int i=0;i<64512;i++){
        //Each instance of 1024 bytes
        arr.add(bt.createObject(1024));

    }

    BufferedReader br = new BufferedReader(new
              InputStreamReader(System.in));
    try {
        br.readLine();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    System.out.println("Now releasing.."+arr.size());

    for(int i=0;i<arr.size();i++){
        ByteBuf b = arr.remove(i);
        b.release();
    }

    System.out.println("Now array size ="+arr.size());

    Thread.sleep(100000);

}

Выход:

Теперь выпускаем.64512 После размера массива =32256

Понятия не имею, только ровно половина записей была удалена. Тем не менее, в ArrayList есть записи ByteBuf.

Answer 1

Это потому, что вы используете:

 for(int i=0;i<arr.size();i++){
    ByteBuf b = arr.remove(i);
    b.release();
}

Это не будет работать, когда вы увеличиваете индекс на 0, но также удаляете буфер. Таким образом, вы пропустите буферы.

Лучше использовать Queue и просто использовать poll();

 Queue<ByteBuf> arr = new ArrayDeque<>();
 for(;;){
    ByteBuf b = arr.poll();
    if (b == null) {
        break;
    }
    b.release();
}