public class ClosureExample {
    public static void main(String[] args) {
        String greeting = "Hello";

        Runnable r = () -> {
            System.out.println(greeting + ", Lambda!");
        };

        r.run();
    }
}

public class ClosureError {
    public static void main(String[] args) {
        int counter = 0;

        Runnable r = () -> {
            // خطا: چون counter بعداً تغییر داده می‌شه
            System.out.println(counter);
        };

        counter++; //  این باعث می‌شه متغیر دیگه effectively final نباشه
    }
}

public class ClosureCorrect {
    public static void main(String[] args) {
        final int counter = 0;

        Runnable r = () -> {
            System.out.println(counter);
        };

        r.run(); //  بدون خطا
    }
}

#کاربرـپیشرفته

🆔 @javapro_ir
🆔 @group_javapro

import java.util.concurrent.CompletableFuture;

public class AsyncExample {
    public static void main(String[] args) {
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            // یه تسک ساده
            System.out.println("در حال اجرا در یک Thread جداگانه: " + Thread.currentThread().getName());
        });

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

        System.out.println("کار اصلی تمام شد!");
    }
}

import java.util.concurrent.CompletableFuture;

public class SupplyExample {
    public static void main(String[] args) {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            return "Hello from Async Task!";
        });

        // گرفتن نتیجه
        String result = future.join();
        System.out.println("نتیجه: " + result);
    }
}

import java.util.concurrent.CompletableFuture;

public class CombineExample {
    public static void main(String[] args) {
        CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Java");
        CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> "Async");

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

        System.out.println(combined.join()); // خروجی: Java Async
    }
}

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

🆔 @javapro_ir
🆔 @group_javapro

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