Demo of CountDownLatch and CyclicBarrier in concurrent data processing,
similar like fork join pool with more granular control over data flow