diff -r c7c26511138f -r 7c4a911dc066 buildframework/helium/sf/java/legacy/src/com/nokia/ant/taskdefs/HlmExecTask.java --- a/buildframework/helium/sf/java/legacy/src/com/nokia/ant/taskdefs/HlmExecTask.java Wed Jun 16 16:51:40 2010 +0300 +++ b/buildframework/helium/sf/java/legacy/src/com/nokia/ant/taskdefs/HlmExecTask.java Fri Aug 13 14:59:05 2010 +0300 @@ -17,10 +17,12 @@ package com.nokia.ant.taskdefs; -import org.apache.tools.ant.taskdefs.ExecTask; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.ThreadPoolExecutor; + import org.apache.tools.ant.BuildException; - -import java.util.concurrent.*; +import org.apache.tools.ant.taskdefs.ExecTask; /** * Exec task using shared thread pool @@ -39,8 +41,7 @@ public void execute() { String property = getProject().getProperty("number.of.threads"); - if (property != null) - { + if (property != null) { ((ThreadPoolExecutor)threadPool).setCorePoolSize(Integer.parseInt(property)); ((ThreadPoolExecutor)threadPool).setMaximumPoolSize(Integer.parseInt(property)); } @@ -48,18 +49,20 @@ threadPool.submit(taskRunnable); try { synchronized (semaphore) { - while (!taskRunnable.isFinished()) + while (!taskRunnable.isFinished()) { semaphore.wait(); + } } } catch (InterruptedException e) { e.printStackTrace(); } Throwable exception = taskRunnable.getException(); if (exception != null) { - if (exception instanceof BuildException) + if (exception instanceof BuildException) { throw (BuildException)exception; - else + } else { exception.printStackTrace(); + } } }