Mailing-List: contact dev-help@ant.apache.org; run by ezmlm
Precedence: bulk
Reply-To: "Ant Developers List" <dev@ant.apache.org>
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r577261 -
 /ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/Parallel.java
Date: Wed, 19 Sep 2007 12:00:47 -0000
To: ant-cvs@apache.org
From: peterreilly@apache.org
Message-Id: <20070919120047.BB7B11A9832@eris.apache.org>

Author: peterreilly
Date: Wed Sep 19 05:00:46 2007
New Revision: 577261

URL: http://svn.apache.org/viewvc?rev=577261&view=rev
Log:
checkstyle

Modified:
    ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/Parallel.java

Modified: ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/Parallel.java
URL: http://svn.apache.org/viewvc/ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/Parallel.java?rev=577261&r1=577260&r2=577261&view=diff
==============================================================================
--- ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/Parallel.java (original)
+++ ant/core/trunk/src/main/org/apache/tools/ant/taskdefs/Parallel.java Wed Sep 19 05:00:46 2007
@@ -49,6 +49,8 @@
 public class Parallel extends Task
                       implements TaskContainer {
 
+    private static final int NUMBER_TRIES = 100;
+
     /** Class which holds a list of tasks to execute */
     public static class TaskList implements TaskContainer {
         /** Collection holding the nested tasks */
@@ -354,7 +356,7 @@
             killAll(running);
         }
 
-        if (interrupted){
+        if (interrupted) {
             throw new BuildException("Parallel execution interrupted.");
         }
         if (timedOut) {
@@ -383,30 +385,26 @@
 
     /**
      * Doesn't do anything if all threads where already gone,
-     * else it tries to kill the threads 3 times.
+     * else it tries to interrupt the threads 100 times.
      * @param running The list of tasks that may currently be running.
      */
     private void killAll(TaskRunnable[] running) {
         boolean oneAlive;
         int tries = 0;
-        do
-        {
+        do {
             oneAlive = false;
-            for (int i = 0; i < running.length; i++)
-            {
-                if (running[i] != null && ! running[i].isFinished())
-                {
+            for (int i = 0; i < running.length; i++) {
+                if (running[i] != null && !running[i].isFinished()) {
                     running[i].interrupt();
                     Thread.yield();
                     oneAlive = true;
                 }
             }
-            if (oneAlive)
-            {
+            if (oneAlive) {
                 tries++;
                 Thread.yield();
             }
-        } while (oneAlive && tries < 100);        
+        } while (oneAlive && tries < NUMBER_TRIES);
     }
 
     /**
@@ -484,8 +482,7 @@
             return finished;
         }
 
-        void interrupt()
-        {
+        void interrupt() {
             thread.interrupt();
         }
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@ant.apache.org
For additional commands, e-mail: dev-help@ant.apache.org