为什么在执行Java流终端操作时没有垃圾收集对象？

Question

我试图理解是什么保存了对对象的引用，使得它们在执行Java流终端操作时不符合垃圾收集的条件？

这是我的测试代码

import java.util.stream.IntStream;
import java.util.stream.Stream;

class Scratch {
   public static void main(String[] args) {
       Stream<LargeObject> objectStream = IntStream.rangeClosed(0, 1000000).mapToObj(LargeObject::new);
       objectStream.peek(obj -> {
           try {
               Thread.sleep(1);

               if (obj.i % 100 == 0) {
                   System.out.println("Processed: " + obj.i);
               }

               if (obj.i % 10000 == 0) {
                   System.out.println("Calling GC");
                   System.gc();
               } 

           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       })
         .map(largeObject -> new Object())
         .count();
   }

   private static class LargeObject {
       private final int i;
       private final byte[] alloc = new byte[1024];

       private LargeObject(int i) {
           this.i = i;
       }

       @Override
       protected void finalize() throws Throwable {
           super.finalize();
           System.out.println("" + i + " collected");
       }
   }
 }

从未调用LargetObject的finalize方法。

我的想法是一旦. map（largeObject-

为什么这不会发生？也许真的可以做些什么？

Answer 1

这与最终确定和gc无关。你应该提到你是在java-9或更高版本（我想是的，但应该是这样）。我将简化这一点：

    long howMany = List.of(1, 2, 3)
                       .stream()
                       .map(x -> {
                           System.out.println("mapping = " + x);
                           return x;
                       })
                       .count();

    System.out.println(howMany);

由于初始流的大小是已知的，并且没有改变，因此根本不会执行peek和map（因此不会生成垃圾）。看看这个：

public static void main(String[] args) {

    List<Integer> list = List.of(1, 2, 3);
    Stream<Integer> one = isSized(list.stream());
    Stream<Integer> two = isSized(one.map(x -> {
        System.out.println("mapping = " + x);
        return x;
    }));

    long count = isSized(two).count();

    System.out.println(count);
}

private static Stream<Integer> isSized(Stream<Integer> stream) {
    Spliterator<Integer> sp = stream.spliterator();
    System.out.println(sp.hasCharacteristics(Spliterator.SIZED));
    return StreamSupport.stream(sp, stream.isParallel());
}

用java-8编译相同的代码，你会看到不同的画面。