[logback-dev] svn commit: r2269 - logback/trunk/logback-core/src/test/java/ch/qos/logback/core/issue

[noreply.ceki at qos.ch]

Author: ceki
Date: Fri Jun  5 15:08:50 2009
New Revision: 2269

Modified:
   logback/trunk/logback-core/src/test/java/ch/qos/logback/core/issue/LockingInJava.java

Log:
interrupt from the end 

Modified: logback/trunk/logback-core/src/test/java/ch/qos/logback/core/issue/LockingInJava.java
==============================================================================
--- logback/trunk/logback-core/src/test/java/ch/qos/logback/core/issue/LockingInJava.java	(original)
+++ logback/trunk/logback-core/src/test/java/ch/qos/logback/core/issue/LockingInJava.java	Fri Jun  5 15:08:50 2009
@@ -1,8 +1,8 @@
 package ch.qos.logback.core.issue;
 
 /**
- * Short sample code illustrating locking policies in the JDK.
- * See http://jira.qos.ch/browse/LBCORE-97 for a discussion.
+ * Short sample code illustrating locking policies in the JDK. See
+ * http://jira.qos.ch/browse/LBCORE-97 for a discussion.
  * 
  * @author Joern Huxhorn
  * @author Ceki Gulcu
@@ -22,7 +22,7 @@
     printResults();
   }
 
-  public static void printEnvironmentInfo()  {
+  public static void printEnvironmentInfo() {
     System.out.println("java.runtime.version = "
         + System.getProperty("java.runtime.version"));
     System.out.println("java.vendor          = "
@@ -40,12 +40,16 @@
       RUNNABLE_ARRAY[i] = new LockingInJava();
       THREAD_ARRAY[i] = new Thread(RUNNABLE_ARRAY[i]);
     }
-    for(Thread t: THREAD_ARRAY) {
+    for (Thread t : THREAD_ARRAY) {
       t.start();
     }
     // let the threads run for a while
     Thread.sleep(10000);
-    for(Thread t: THREAD_ARRAY) {
+    for (int i = THREAD_COUNT - 1; i <= 0; i--) {
+      THREAD_ARRAY[i].interrupt();
+    }
+
+    for (Thread t : THREAD_ARRAY) {
       t.interrupt();
     }
     Thread.sleep(100); // wait a moment for termination, to lazy for join ;)