diff --git a/thread-pool/src/main/java/com/iluwatar/App.java b/thread-pool/src/main/java/com/iluwatar/App.java
index faf592178..101dde037 100644
--- a/thread-pool/src/main/java/com/iluwatar/App.java
+++ b/thread-pool/src/main/java/com/iluwatar/App.java
@@ -1,7 +1,41 @@
 package com.iluwatar;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
 public class App {
 	
     public static void main( String[] args ) {
+    	
+    	System.out.println("Program started");
+    	
+    	List<Task> tasks = new ArrayList<>();
+    	tasks.add(new PotatoPeelingTask(3));
+    	tasks.add(new PotatoPeelingTask(6));
+    	tasks.add(new CoffeeMakingTask(2));
+    	tasks.add(new CoffeeMakingTask(6));
+    	tasks.add(new PotatoPeelingTask(4));
+    	tasks.add(new CoffeeMakingTask(2));
+    	tasks.add(new PotatoPeelingTask(4));
+    	tasks.add(new CoffeeMakingTask(9));
+    	tasks.add(new PotatoPeelingTask(3));
+    	tasks.add(new CoffeeMakingTask(2));
+    	tasks.add(new PotatoPeelingTask(4));
+    	tasks.add(new CoffeeMakingTask(2));
+    	tasks.add(new CoffeeMakingTask(7));
+    	tasks.add(new PotatoPeelingTask(4));
+    	tasks.add(new PotatoPeelingTask(5));
+    	
+    	ExecutorService executor = Executors.newFixedThreadPool(3);
+    	for (int i=0; i<tasks.size(); i++) {
+	    	Runnable worker = new Worker(tasks.get(i));
+	    	executor.execute(worker);
+    	}
+    	executor.shutdown();
+    	while (!executor.isTerminated()) {
+    	}
+    	System.out.println("Program finished");
     }
 }
diff --git a/thread-pool/src/main/java/com/iluwatar/CoffeeMakingTask.java b/thread-pool/src/main/java/com/iluwatar/CoffeeMakingTask.java
new file mode 100644
index 000000000..fb4f5924b
--- /dev/null
+++ b/thread-pool/src/main/java/com/iluwatar/CoffeeMakingTask.java
@@ -0,0 +1,15 @@
+package com.iluwatar;
+
+public class CoffeeMakingTask extends Task {
+
+	private static int TIME_PER_CUP = 300;
+	
+	public CoffeeMakingTask(int numCups) {
+		super(numCups * TIME_PER_CUP);
+	}
+
+	@Override
+	public String toString() {
+		return String.format("%s %s", this.getClass().getSimpleName(), super.toString());
+	}
+}
diff --git a/thread-pool/src/main/java/com/iluwatar/PotatoPeelingTask.java b/thread-pool/src/main/java/com/iluwatar/PotatoPeelingTask.java
new file mode 100644
index 000000000..671c736d9
--- /dev/null
+++ b/thread-pool/src/main/java/com/iluwatar/PotatoPeelingTask.java
@@ -0,0 +1,15 @@
+package com.iluwatar;
+
+public class PotatoPeelingTask extends Task {
+
+	private static int TIME_PER_POTATO = 500;
+	
+	public PotatoPeelingTask(int numPotatoes) {
+		super(numPotatoes * TIME_PER_POTATO);
+	}
+	
+	@Override
+	public String toString() {
+		return String.format("%s %s", this.getClass().getSimpleName(), super.toString());
+	}
+}
diff --git a/thread-pool/src/main/java/com/iluwatar/Task.java b/thread-pool/src/main/java/com/iluwatar/Task.java
new file mode 100644
index 000000000..d6e925df5
--- /dev/null
+++ b/thread-pool/src/main/java/com/iluwatar/Task.java
@@ -0,0 +1,27 @@
+package com.iluwatar;
+
+public abstract class Task {
+
+	private static int nextId = 1;
+	
+	private int id;
+	private int timeMs;
+	
+	public Task(int timeMs) {
+		this.id = nextId++;
+		this.timeMs = timeMs;
+	}
+	
+	public int getId() {
+		return id;
+	}
+	
+	public int getTimeMs() {
+		return timeMs;
+	}
+	
+	@Override
+	public String toString() {
+		return String.format("id=%d timeMs=%d", id, timeMs);
+	}
+}
diff --git a/thread-pool/src/main/java/com/iluwatar/Worker.java b/thread-pool/src/main/java/com/iluwatar/Worker.java
new file mode 100644
index 000000000..6044ac62c
--- /dev/null
+++ b/thread-pool/src/main/java/com/iluwatar/Worker.java
@@ -0,0 +1,20 @@
+package com.iluwatar;
+
+public class Worker implements Runnable {
+	
+	private Task task;
+
+	public Worker(Task task) {
+		this.task = task;
+	}
+	
+	@Override
+	public void run() {
+		System.out.println(String.format("%s processing %s", Thread.currentThread().getName(), task.toString()));
+		try {
+			Thread.sleep(task.getTimeMs());
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+	}
+}