[JAVA-9895] Split concurrency-basic-2 module

core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/interrupt/CustomInterruptedException.java

@@ -0,0 +1,10 @@
+package com.baeldung.concurrent.interrupt;
+
+public class CustomInterruptedException extends Exception {
+   
+    private static final long serialVersionUID = 1L;
+
+    CustomInterruptedException(String message) {
+        super(message);
+    }
+}

core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/interrupt/InterruptExample.java

@@ -0,0 +1,47 @@
+package com.baeldung.concurrent.interrupt;
+
+public class InterruptExample extends Thread {
+    
+    public static void propagateException() throws InterruptedException {
+        Thread.sleep(1000);
+        Thread.currentThread().interrupt();
+        if (Thread.interrupted()) {
+            throw new InterruptedException();
+        }
+    }
+
+    public static Boolean restoreTheState() {
+        InterruptExample thread1 = new InterruptExample();
+        thread1.start();
+        thread1.interrupt();
+        return thread1.isInterrupted();
+    }
+
+    public void run() {
+        try {
+            Thread.sleep(1000);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+    }
+    
+    public static void throwCustomException() throws Exception {
+
+        Thread.sleep(1000);
+        Thread.currentThread().interrupt();
+        if (Thread.interrupted()) {
+            throw new CustomInterruptedException("This thread was interrupted");
+        }
+    }
+    
+    public static Boolean handleWithCustomException() throws CustomInterruptedException{
+        try {
+            Thread.sleep(1000);
+            Thread.currentThread().interrupt();
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            throw new CustomInterruptedException("This thread was interrupted...");
+        }
+        return Thread.currentThread().isInterrupted();
+    }
+}

core-java-modules/core-java-concurrency-basic-3/src/main/resources/logback.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n
+            </pattern>
+        </encoder>
+    </appender>
+
+    <root level="INFO">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>

core-java-modules/core-java-concurrency-basic-3/src/test/java/com/baeldung/concurrent/interrupt/InterruptExampleUnitTest.java

@@ -0,0 +1,33 @@
+package com.baeldung.concurrent.interrupt;
+
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import org.junit.jupiter.api.Test;
+
+public class InterruptExampleUnitTest {
+
+    @Test
+    public void whenPropagateException_thenThrowsInterruptedException() {
+        assertThrows(InterruptedException.class, InterruptExample::propagateException);
+    }
+
+    @Test
+    public void whenRestoreTheState_thenReturnsTrue() {
+        assertTrue(InterruptExample.restoreTheState());
+    }
+
+    @Test
+    public void whenThrowCustomException_thenContainsExpectedMessage() {
+        Exception exception = assertThrows(CustomInterruptedException.class, InterruptExample::throwCustomException);
+        String expectedMessage = "This thread was interrupted";
+        String actualMessage = exception.getMessage();
+
+        assertTrue(actualMessage.contains(expectedMessage));
+    }
+
+    @Test
+    public void whenHandleWithCustomException_thenReturnsTrue() throws CustomInterruptedException{
+        assertTrue(InterruptExample.handleWithCustomException());
+    }
+}