X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=common%2Futil%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fyangtools%2Futil%2FExecutorServiceUtil.java;h=429bb0bd0c0e66ce33b49f6f619bdbb1e004c4ee;hb=41c159ad750e969516f9b5fb4b7edeb5633eff7e;hp=51a8d16f84ce007c3499b8f9e04e78766c310c6e;hpb=c5e58b6841e2f9d9bcd7808d4f3073b1c4792d26;p=yangtools.git

diff --git a/common/util/src/main/java/org/opendaylight/yangtools/util/ExecutorServiceUtil.java b/common/util/src/main/java/org/opendaylight/yangtools/util/ExecutorServiceUtil.java
index 51a8d16f84..429bb0bd0c 100644
--- a/common/util/src/main/java/org/opendaylight/yangtools/util/ExecutorServiceUtil.java
+++ b/common/util/src/main/java/org/opendaylight/yangtools/util/ExecutorServiceUtil.java
@@ -7,18 +7,16 @@
  */
 package org.opendaylight.yangtools.util;
 
+import com.google.common.util.concurrent.ForwardingBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.RejectedExecutionException;
 import java.util.concurrent.RejectedExecutionHandler;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.google.common.util.concurrent.ForwardingBlockingQueue;
-
 /**
  * Utility methods for dealing with {@link ExecutorService}s.
  */
@@ -26,7 +24,7 @@ public final class ExecutorServiceUtil {
     private static final class WaitInQueueExecutionHandler implements RejectedExecutionHandler {
         @Override
         public void rejectedExecution(final Runnable r, final ThreadPoolExecutor executor) {
-            if( executor.isShutdown() ) {
+            if (executor.isShutdown() ) {
                 throw new RejectedExecutionException( "Executor has been shutdown." );
             }
 
@@ -90,7 +88,7 @@ public final class ExecutorServiceUtil {
         executor.shutdown();
 
         try {
-            if(!executor.awaitTermination(timeout, unit)) {
+            if (!executor.awaitTermination(timeout, unit)) {
                 executor.shutdownNow();
             }
         } catch( InterruptedException e ) {