Add producer test app which can control the throughput and Fix ConcurrentModificationException