PipeLeakRepro.java

import com.zaxxer.nuprocess.*;

import java.util.concurrent.*;
import java.util.*;

class PipeLeakRepro {
    static class ProcessHandler extends NuAbstractProcessHandler {
        private NuProcess nuProcess;

        @Override
        public void onStart(NuProcess nuProcess) {
            this.nuProcess = nuProcess;
            nuProcess.closeStdin(true);
        }
    }

    private static void doNuProcess() throws Exception {
        NuProcessBuilder pb = new NuProcessBuilder(Arrays.asList("/bin/echo", "test"));
        ProcessHandler handler = new ProcessHandler();
        pb.setProcessListener(handler);
        NuProcess process = pb.start();
        process.waitFor(0, TimeUnit.SECONDS); // when 0 is used for waitFor() the wait is infinite                                                                                                              
    }

    public static void main(String[] args) throws Exception {
        int i = 0;
        while (true) {
            doNuProcess();
            if (i++ == 2048) {
                System.out.println("pipes start leaking");
            }
        }
    }
}