implemented cacheable AsyncRequestProcessor

src/main/java/mate/academy/AsyncRequestProcessor.java

@@ -1,16 +1,31 @@
 package mate.academy;
 
+import java.util.Map;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Executor;
 
 public class AsyncRequestProcessor {
     private final Executor executor;
+    private Map<String, CompletableFuture<UserData>> cache;
 
     public AsyncRequestProcessor(Executor executor) {
         this.executor = executor;
+        cache = new ConcurrentHashMap<>();
     }
 
     public CompletableFuture<UserData> processRequest(String userId) {
-        return null;
+        return cache.computeIfAbsent(userId, id ->
+                CompletableFuture.supplyAsync(() -> {
+                    try {
+                        UserData userData = new UserData(userId, "Details for " + id);
+                        Thread.sleep(1000);
+                        return userData;
+                    } catch (InterruptedException e) {
+                        Thread.currentThread().interrupt();
+                        throw new RuntimeException("Request for " + id + " was interrupted");
+                    }
+                },executor)
+        );
     }
 }

src/main/java/mate/academy/Main.java

@@ -2,14 +2,14 @@
 
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 public class Main {
     public static void main(String[] args) {
-        // Feel free to play with AsyncRequestProcessor in this main method if you want
-        ExecutorService executor = null; // Provide implementation that fits your needs
+        ExecutorService executor = Executors
+                .newFixedThreadPool(3);
         AsyncRequestProcessor asyncRequestProcessor = new AsyncRequestProcessor(executor);
 
-        // Simulating multiple concurrent requests
         String[] userIds = {"user1", "user2", "user3", "user1"}; // Note: "user1" is repeated
         CompletableFuture<?>[] futures = new CompletableFuture[userIds.length];
 
@@ -19,7 +19,6 @@ public static void main(String[] args) {
                     .thenAccept(userData -> System.out.println("Processed: " + userData));
         }
 
-        // Wait for all futures to complete
         CompletableFuture.allOf(futures).join();
         executor.shutdown();
     }