Preserve interrupted flag on InterruptedExceptions

This allows higher level interruption handlers to handle thread interruption appropriately.
wendykierp · Jan 24, 2018 · 98159b6 · 98159b6
1 parent 3c3253f
commit 98159b6
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/main/java/org/jtransforms/utils/CommonUtils.java b/src/main/java/org/jtransforms/utils/CommonUtils.java
@@ -69,6 +69,7 @@ public static void sleep(long millis)
         try {
             Thread.sleep(millis);
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             e.printStackTrace();
         }
     }
@@ -3786,6 +3787,7 @@ public void run()
         try {
             ConcurrencyUtils.waitForCompletion(futures);
         } catch (InterruptedException ex) {
+            Thread.currentThread().interrupt();
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
         } catch (ExecutionException ex) {
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -3860,6 +3862,7 @@ public void run()
         try {
             ConcurrencyUtils.waitForCompletion(futures);
         } catch (InterruptedException ex) {
+            Thread.currentThread().interrupt();
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
         } catch (ExecutionException ex) {
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -8984,6 +8987,7 @@ public void run()
         try {
             ConcurrencyUtils.waitForCompletion(futures);
         } catch (InterruptedException ex) {
+            Thread.currentThread().interrupt();
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
         } catch (ExecutionException ex) {
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -9058,6 +9062,7 @@ public void run()
         try {
             ConcurrencyUtils.waitForCompletion(futures);
         } catch (InterruptedException ex) {
+            Thread.currentThread().interrupt();
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
         } catch (ExecutionException ex) {
             Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -11130,6 +11135,7 @@ public void run()
             try {
                 ConcurrencyUtils.waitForCompletion(futures);
             } catch (InterruptedException ex) {
+                Thread.currentThread().interrupt();
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
             } catch (ExecutionException ex) {
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -11172,6 +11178,7 @@ public void run()
             try {
                 ConcurrencyUtils.waitForCompletion(futures);
             } catch (InterruptedException ex) {
+                Thread.currentThread().interrupt();
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
             } catch (ExecutionException ex) {
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -11214,6 +11221,7 @@ public void run()
             try {
                 ConcurrencyUtils.waitForCompletion(futures);
             } catch (InterruptedException ex) {
+                Thread.currentThread().interrupt();
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
             } catch (ExecutionException ex) {
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
@@ -11256,6 +11264,7 @@ public void run()
             try {
                 ConcurrencyUtils.waitForCompletion(futures);
             } catch (InterruptedException ex) {
+                Thread.currentThread().interrupt();
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);
             } catch (ExecutionException ex) {
                 Logger.getLogger(CommonUtils.class.getName()).log(Level.SEVERE, null, ex);