Interrupted thread before logging (eugenp#3563)

Switcher05 · Jan 31, 2018 · 3e4b6df · 3e4b6df
1 parent 43a4d08
commit 3e4b6df
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/core-java-concurrency/src/main/java/com/baeldung/concurrent/waitandnotify/Data.java b/core-java-concurrency/src/main/java/com/baeldung/concurrent/waitandnotify/Data.java
@@ -1,7 +1,5 @@
 package com.baeldung.concurrent.waitandnotify;
 
-import org.slf4j.Logger;
-
 public class Data {
     private String packet;
 
@@ -14,6 +12,7 @@ public synchronized String receive() {
             try {
                 wait();
             } catch (InterruptedException e) {
+                Thread.currentThread().interrupt(); 
                 System.out.println("Thread Interrupted");
             }
         }
@@ -28,6 +27,7 @@ public synchronized void send(String packet) {
             try { 
                 wait();
             } catch (InterruptedException e) {
+                Thread.currentThread().interrupt(); 
                 System.out.println("Thread Interrupted");
             }
         }

diff --git a/core-java-concurrency/src/main/java/com/baeldung/concurrent/waitandnotify/Receiver.java b/core-java-concurrency/src/main/java/com/baeldung/concurrent/waitandnotify/Receiver.java
@@ -20,6 +20,7 @@ public void run() {
             try {
                 Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 5000));
             } catch (InterruptedException e) {
+                Thread.currentThread().interrupt(); 
                 System.out.println("Thread Interrupted");
             }
         }

diff --git a/core-java-concurrency/src/main/java/com/baeldung/concurrent/waitandnotify/Sender.java b/core-java-concurrency/src/main/java/com/baeldung/concurrent/waitandnotify/Sender.java
@@ -25,6 +25,7 @@ public void run() {
             try {
                 Thread.sleep(ThreadLocalRandom.current().nextInt(1000, 5000));
             } catch (InterruptedException e) {
+                Thread.currentThread().interrupt(); 
                 System.out.println("Thread Interrupted");
             }
         }

diff --git a/...ncurrency/src/test/java/com/baeldung/concurrent/waitandnotify/NetworkIntegrationTest.java b/...ncurrency/src/test/java/com/baeldung/concurrent/waitandnotify/NetworkIntegrationTest.java
@@ -57,7 +57,8 @@ public void givenSenderAndReceiver_whenSendingPackets_thenNetworkSynchronized()
             sender.join();
             receiver.join();
         } catch (InterruptedException e) {
-            e.printStackTrace();
+            Thread.currentThread().interrupt(); 
+            System.out.println("Thread Interrupted");
         }
 
         assertEquals(expected, outContent.toString());