ThreadSync

ThreadPoolProject/src/main/java/SynchronizedQueue.java

@@ -37,7 +37,7 @@ public class SynchronizedQueue<T> {
         while (queue.isEmpty()) {
             wait();
         }
-
+        notifyAll();
         // Remove and return the element from the queue
         return queue.poll();
     }

ThreadPoolProject/src/main/java/ThreadPoolMain.java

@@ -3,10 +3,10 @@ public class ThreadPoolMain {
     public static void main(String[] args) throws Exception {
 
         // Create a thread pool with 3 threads and a maximum of 10 tasks
-        ThreadPool threadPool = new ThreadPool(3, 10);
+        ThreadPool threadPool = new ThreadPool(3, 100);
 
         // Execute 10 tasks
-        for(int i=0; i<10; i++) {
+        for(int i=0; i<1000; i++) {
 
             int taskNo = i;