SemaphoreTest++

Author: inbravo

src/main/java/com/inbravo/concurrency/SemaphoreTest.java

@@ -20,37 +20,24 @@ public static final void main(final String... args) {
     /* Create new instance of lock test */
     final SemaphoreTest lockTest = new SemaphoreTest();
 
-    /* Start first anonymous thread */
-    new Thread("First-Thread") {
+    for (int i = 0; i < 100; i++) {
 
-      @Override
-      public void run() {
+      /* Spawn several anonymous thread */
+      new Thread("Thread-" + i) {
 
-        if (SafetyMode.SAFE.equals(_MODE)) {
+        @Override
+        public void run() {
 
-          lockTest.iAmThreadSafe();
-        } else {
+          if (SafetyMode.SAFE.equals(_MODE)) {
 
-          lockTest.iAmNotThreadSafe();
-        }
-      }
-    }.start();
-
-    /* Start second anonymous thread */
-    new Thread("Second-Thread") {
-
-      @Override
-      public void run() {
+            lockTest.iAmThreadSafe();
+          } else {
 
-        if (SafetyMode.SAFE.equals(_MODE)) {
-
-          lockTest.iAmThreadSafe();
-        } else {
-
-          lockTest.iAmNotThreadSafe();
+            lockTest.iAmNotThreadSafe();
+          }
         }
-      }
-    }.start();
+      }.start();
+    }
   }
 
   /**
@@ -66,15 +53,15 @@ private final void iAmNotThreadSafe() {
     try {
 
       /* Print current thread info */
-      System.out.println(Thread.currentThread().getName() + " is inside critical section");
+      System.out.println(Thread.currentThread().getName() + " is inside critical section at time : " + System.currentTimeMillis());
 
       /* Sleep this thread so that another thread can do the same operation */
       Thread.sleep(1000);
 
     } catch (final InterruptedException e) {
       e.printStackTrace();
     } finally {
-      System.out.println(Thread.currentThread().getName() + " is out of critical section");
+      System.out.println(Thread.currentThread().getName() + " is out of critical section at time : " + System.currentTimeMillis());
     }
   }
 
@@ -94,7 +81,7 @@ private final void iAmThreadSafe() {
       lock.acquire();
 
       /* Print current thread info */
-      System.out.println(Thread.currentThread().getName() + " is inside critical section");
+      System.out.println(Thread.currentThread().getName() + " is inside critical section at time : " + System.currentTimeMillis());
 
       /* Sleep this thread so that another thread can do the same operation */
       Thread.sleep(1000);
@@ -105,7 +92,7 @@ private final void iAmThreadSafe() {
 
       /* Release the lock */
       lock.release();
-      System.out.println(Thread.currentThread().getName() + " is out of critical section");
+      System.out.println(Thread.currentThread().getName() + " is out of critical section at time : " + System.currentTimeMillis());
     }
   }