Demonstration of the case where inner future doesn't receive interruption signal - it has to be explicitly set by outerExecutorService lambda

InnerInterruptionTest.java

package com.glovoapp.jvmkit.context.demo.app.models;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicReference;

public class InnerInterruptionTest {

    public static void main(String[] args) throws InterruptedException {

        // Create a ExecutorService for managing threads
        ExecutorService outerExecutorService = Executors.newSingleThreadExecutor();
        ExecutorService innerExecutorService = Executors.newSingleThreadExecutor();

        AtomicReference<Future<String>> innerFuture = new AtomicReference<>();
        Future<String> outerFuture = outerExecutorService.submit(() -> {
            // Create a Future to hold the result of a task
            innerFuture.set(innerExecutorService.submit(() -> {
                try {
                    // Simulate some time-consuming operation
                    Thread.sleep(5000); // Sleep for 5 seconds
                    System.out.println("Task completed successfully!");
                    return "Done";
                } catch (InterruptedException e) {
                    // Handle interruption
                    System.out.println("Task was interrupted!");
                    return "Error";
                }
            }));

            return innerFuture.get().get();
        });

        Thread.sleep(1000);
        outerFuture.cancel(true);

        Thread.sleep(1000);
    }
}