public class EmailSender implements Runnable {

String message;

EmailSender (String message) {

this.message = message;

}

public void run() {

try {

sendEmail(message);

} CATCH (Exception E) {

e.printStackTrace();

}

}

PRIVATE void sendEmail(String message2) {

System.out.println("Sending Email" + message);

}

}

public class TestThreadPool {

public static void main(String[] args) {

 //Let us START the Worker Threads

static final Integer NTHREDS=5;

ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);

for (int i = 0; i < 6; i++) {

Runnable worker = new EmailSender("Hi Email from java");

executor.execute(worker);

}

// This will make the executor accept no new threads

// and finish all existing threads in the queue

executor.shutdoOWN();

 // WAIT until all threads are finish

while (!executor.isTerminated()) {

} 

}

}

public class EmailSender implements Runnable {

String message;

EmailSender (String message) {

this.message = message;

}

public void run() {

try {

sendEmail(message);

} catch (Exception e) {

e.printStackTrace();

}

}

private void sendEmail(String message2) {

System.out.println("Sending Email" + message);

}

}

public class TestThreadPool {

public static void main(String[] args) {

 //Let us start the Worker Threads

static final Integer NTHREDS=5;

ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);

for (int i = 0; i < 6; i++) {

Runnable worker = new EmailSender("Hi Email from java");

executor.execute(worker);

}

// This will make the executor accept no new threads

// and finish all existing threads in the queue

executor.shutdoOWN();

 // Wait until all threads are finish

while (!executor.isTerminated()) {

} 

}

}