WorkerThread.java

class WorkerThread implements Runnable 
{
    private String name;
    private CountDownLatch countDownLatch;


    WorkerThread(String name, CountDownLatch countDownLatch) 
    {
        this.name = name;
        this.countDownLatch = countDownLatch;

    }

    @Override
    public void run() 
    {
        try {
            Thread.sleep(5000);
            System.out.println(" thread [" + name + "] completed ");
            countDownLatch.countDown();
        } catch (InterruptedException ex) {
            System.out.println(" sleeping thread get interrupted ");
        }
    }
}