Method main

test/test/proc/IoIntensiveApp.java:22–56

(String[] args)

    private static final int BLOCK = 64 * 1024 * 1024;

    public static void main(String[] args) throws Exception {
        Path tmp = Files.createTempFile("proc-test", ".tmp");

        // burn some cpu to pass the min cpu % threshold
        new Thread(() -> {
            while (true) {
                long n = random.nextLong();
                if (Long.toString(n).hashCode() == 0) {
                    System.out.println(n);
                }
            }
        }).start();

        // write
        byte[] payload = new byte[BLOCK];
        random.nextBytes(payload);

        try (FileChannel ch = FileChannel.open(tmp, StandardOpenOption.CREATE, StandardOpenOption.WRITE,
                StandardOpenOption.DSYNC)) {
            ByteBuffer buf = ByteBuffer.wrap(payload);
            while (buf.hasRemaining()) {
                ch.write(buf);
            }

            ch.force(true);
        }

        // read
        try (FileChannel f = FileChannel.open(tmp, StandardOpenOption.READ)) {
            ByteBuffer b = ByteBuffer.allocate(BLOCK);
            f.read(b);
        }

        Thread.sleep(20000);
    }
}