ConcurrentMap<String, Integer> concurrentMap = new ConcurrentHashMap<>();
ConcurrentLinkedQueue<String> concurrentQueue = new ConcurrentLinkedQueue<>();
ExecutorService executorService = Executors.newFixedThreadPool(5);
executorService.submit(new Runnable() {
public void run() {
}
});
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);
scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
public void run() {
}
}, 0, 1, TimeUnit.SECONDS);
CountDownLatch latch = new CountDownLatch(3);
// ...
latch.await();
// ...
latch.countDown();
