I think we can use `executionService.getScheduledExecutor()` instead of creating a new thread for each replicated map.