test

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

@@ -1,16 +1,48 @@
 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 final Map<String, UserData> cache =
+            new ConcurrentHashMap<>();
+
     public AsyncRequestProcessor(Executor executor) {
         this.executor = executor;
     }
 
     public CompletableFuture<UserData> processRequest(String userId) {
-        return null;
+
+        // Return cached value immediately
+        if (cache.containsKey(userId)) {
+            return CompletableFuture.completedFuture(
+                    cache.get(userId)
+            );
+        }
+
+        // Asynchronous processing
+        return CompletableFuture.supplyAsync(() -> {
+            try {
+                // Simulate database/API delay
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+                throw new RuntimeException(e);
+            }
+
+            UserData userData =
+                    new UserData(userId,
+                            "Details for " + userId);
+
+            // Save to cache
+            cache.put(userId, userData);
+
+            return userData;
+        }, executor);
     }
 }
+

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

@@ -2,25 +2,33 @@
 
 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
-        AsyncRequestProcessor asyncRequestProcessor = new AsyncRequestProcessor(executor);
+        ExecutorService executor = Executors.newFixedThreadPool(4);
+
+        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];
+        String[] userIds = {"user1", "user2", "user3", "user1"};
+
+        CompletableFuture<?>[] futures =
+                new CompletableFuture[userIds.length];
 
         for (int i = 0; i < userIds.length; i++) {
             String userId = userIds[i];
+
             futures[i] = asyncRequestProcessor.processRequest(userId)
-                    .thenAccept(userData -> System.out.println("Processed: " + userData));
+                    .thenAccept(userData ->
+                            System.out.println("Processed: " + userData));
         }
 
         // Wait for all futures to complete
         CompletableFuture.allOf(futures).join();
+
         executor.shutdown();
     }
 }
+

src/main/java/mate/academy/UserData.java

@@ -3,3 +3,4 @@
 public record UserData(String userId, String details) {
 
 }
+