Correct handling of Thread.interrupted().

1 files changed, 3 insertions, 0 deletions

diff --git a/same/src/main/java/com/orbekk/same/VariableUpdaterTask.java b/same/src/main/java/com/orbekk/same/VariableUpdaterTask.java
index 44f63fe..471dbc6 100644
--- a/same/src/main/java/com/orbekk/same/VariableUpdaterTask.java
+++ b/same/src/main/java/com/orbekk/same/VariableUpdaterTask.java
@@ -35,6 +35,9 @@ public class VariableUpdaterTask<T> extends Thread
     }
     
     private synchronized void waitFor(AtomicBoolean v) {
+        if (Thread.interrupted()) {
+            return;
+        }
         while(!v.get()) {
             try {
                 wait();