1import java.util.concurrent.CountDownLatch;
2
3public class CountDownLatchExample {
4    private static final int THREAD_COUNT = 3;
5    private static final CountDownLatch latch = new CountDownLatch(THREAD_COUNT);
6
7    public static void main(String[] args) throws InterruptedException {
8        for (int i = 0; i < THREAD_COUNT; i++) {
9            new Thread(new Worker()).start();
10        }
11
12        latch.await(); // Wait until latch count is 0
13        System.out.println("All tasks completed. Continuing execution...");
14    }
15
16    static class Worker implements Runnable {
17        @Override
18        public void run() {
19            try {
20                System.out.println(Thread.currentThread().getName() + " is working on a task...");
21                Thread.sleep(1000); // Simulates task execution
22            } catch (InterruptedException e) {
23                Thread.currentThread().interrupt();
24            } finally {
25                latch.countDown(); // Reduce the count of latch
26                System.out.println(Thread.currentThread().getName() + " completed.");
27            }
28        }
29    }
30}

1import java.util.concurrent.BrokenBarrierException;
2import java.util.concurrent.CyclicBarrier;
3
4public class CyclicBarrierExample {
5    private static final int THREAD_COUNT = 3;
6    private static final CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, 
7        () -> System.out.println("Barrier reached, let's proceed to next phase."));
8
9    public static void main(String[] args) {
10        for (int i = 0; i < THREAD_COUNT; i++) {
11            new Thread(new Worker()).start();
12        }
13    }
14
15    static class Worker implements Runnable {
16        @Override
17        public void run() {
18            try {
19                System.out.println(Thread.currentThread().getName() + " is executing phase...");
20                Thread.sleep(1000); // Simulates task for phase
21                barrier.await(); // Wait for other threads
22                System.out.println(Thread.currentThread().getName() + " is progressing to the next phase.");
23            } catch (InterruptedException | BrokenBarrierException e) {
24                Thread.currentThread().interrupt();
25            }
26        }
27    }
28}