import java.util.concurrent.CompletableFuture;

public class HandleExample {
    public static void main(String[] args) {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            if (true) throw new RuntimeException("خطا در پردازش!");
            return "موفقیت";
        }).handle((result, ex) -> {
            if (ex != null) {
                return "خطا مدیریت شد: " + ex.getMessage();
            }
            return result;
        });

        System.out.println(future.join());
    }
}

import java.util.concurrent.CompletableFuture;

public class ExceptionallyExample {
    public static void main(String[] args) {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            throw new RuntimeException("مشکل پیش اومد!");
        }).exceptionally(ex -> {
            return "خطا: " + ex.getMessage();
        });

        System.out.println(future.join());
    }
}

import java.util.concurrent.CompletableFuture;

public class WhenCompleteExample {
    public static void main(String[] args) {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            if (Math.random() > 0.5) {
                throw new RuntimeException("خطای شانسی!");
            }
            return "کار موفق بود!";
        }).whenComplete((result, ex) -> {
            if (ex != null) {
                System.out.println("❌ خطا: " + ex.getMessage());
            } else {
                System.out.println("✅ نتیجه: " + result);
            }
        });

        // برای اینکه برنامه منتظر بمونه
        future.join();
    }
}

#کاربرـحرفهـای

🆔 @javapro_ir
🆔 @group_javapro

import java.util.concurrent.CompletableFuture;

public class ThenApplyExample {
    public static void main(String[] args) {
        CompletableFuture<String> future = CompletableFuture
            .supplyAsync(() -> "Hello")
            .thenApply(s -> s + " World")
            .thenApply(s -> s.toUpperCase());

        System.out.println(future.join());
    }
}

import java.util.concurrent.CompletableFuture;

public class ThenComposeExample {
    public static void main(String[] args) {
        CompletableFuture<String> future = CompletableFuture
            .supplyAsync(() -> "User123")
            .thenCompose(user -> getUserProfile(user));

        System.out.println(future.join());
    }

    static CompletableFuture<String> getUserProfile(String user) {
        return CompletableFuture.supplyAsync(() -> "Profile of " + user);
    }
}

import java.util.concurrent.CompletableFuture;

public class ThenCombineExample {
    public static void main(String[] args) {
        CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
        CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "World");

        CompletableFuture<String> combined = future1.thenCombine(future2, (a, b) -> a + " " + b);

        System.out.println(combined.join());
    }
}

#کاربرـحرفهـای

🆔 @javapro_ir
🆔 @group_javapro