হোম / Concurrency / CompletableFuture চেইনিং (Chaining)
Concurrency মধ্যম

CompletableFuture চেইনিং (Chaining)

CompletableFuture ব্যবহার করে কোনো ব্লক না করে অ্যাসিঙ্ক্রোনাস অপারেশনগুলিকে চেইন করুন।

কোড তুলনা
✕ Pre-Java 8 
Future<String> future =
    executor.submit(this::fetchData);
String data = future.get(); // blocks
String result = transform(data);
✓ Java 8+ 
CompletableFuture.supplyAsync(
    this::fetchData
)
.thenApply(this::transform)
.thenAccept(IO::println);
এই কোডে সমস্যা দেখছেন? আমাদের জানান।
কেন আধুনিক পদ্ধতি ভালো
🔗

চেইনেবল (Chainable)

অ্যাসিঙ্ক স্টেপগুলিকে একটি পঠনযোগ্য পাইপলাইনে সাজানো যায়।

🚫

নন-ব্লকিং (Non-blocking)

কোনো থ্রেড ফলাফলের জন্য অলসভাবে অপেক্ষা করে না।

🛡️

এরর হ্যান্ডলিং (Error Handling)

exceptionally() এবং handle() মেথডগুলো পরিষ্কারভাবে এরর রিকভারি (error recovery) করার সুবিধা দেয়।

পুরনো পদ্ধতি
ব্লকিং Future.get()
আধুনিক পদ্ধতি
CompletableFuture
JDK থেকে
8
কঠিনতা
মধ্যম
JDK সমর্থন
CompletableFuture চেইনিং (Chaining)
উপলব্ধ

JDK 8 (মার্চ 2014) থেকে ব্যাপকভাবে উপলব্ধ

কীভাবে কাজ করে

CompletableFuture নন-ব্লকিং অ্যাসিঙ্ক (async) পাইপলাইন তৈরি করতে সাহায্য করে। আপনি thenApply, thenCompose, thenAccept মেথডগুলো ব্যবহার করে অপারেশনগুলোকে চেইন করতে পারবেন। exceptionally() মেথড দিয়ে এরর (error) হ্যান্ডেল করা যায় এবং allOf/anyOf মেথড দিয়ে একাধিক ফিউচারকে একত্রিত করা যায়।

সম্পর্কিত ডকুমেন্টেশন
CompletableFuture ↗
প্রমাণ
প্রমাণ সোর্স দেখুন ↗
সম্পর্কিত প্যাটার্ন
Concurrency উন্নত

Stable values

Java 8
private volatile Logger logger;
Logger getLogger() {
    if (logger == null) {
        synchronized (this) {
            if (logger == null)
                logger = createLogger();
        }
    }
    return logger;
}
Java 25 (Preview)
private final StableValue<Logger> logger =
    StableValue.of(this::createLogger);

Logger getLogger() {
    return logger.get();
}
আধুনিক দেখতে হোভার করুন ➜
JDK 25+ →
Concurrency উন্নত

Scoped values

Java 8
static final ThreadLocal<User> CURRENT =
    new ThreadLocal<>();
void handle(Request req) {
    CURRENT.set(authenticate(req));
    try { process(); }
    finally { CURRENT.remove(); }
}
Java 25
static final ScopedValue<User> CURRENT =
    ScopedValue.newInstance();
void handle(Request req) {
    ScopedValue.where(CURRENT,
        authenticate(req)
    ).run(this::process);
}
আধুনিক দেখতে হোভার করুন ➜
JDK 25+ →
Concurrency উন্নত

Structured concurrency

Java 8
ExecutorService exec =
    Executors.newFixedThreadPool(2);
Future<User> u = exec.submit(this::fetchUser);
Future<Order> o = exec.submit(this::fetchOrder);
try {
    return combine(u.get(), o.get());
} finally { exec.shutdown(); }
Java 25 (Preview)
try (var scope = new StructuredTaskScope
        .ShutdownOnFailure()) {
    var u = scope.fork(this::fetchUser);
    var o = scope.fork(this::fetchOrder);
    scope.join().throwIfFailed();
    return combine(u.get(), o.get());
}
আধুনিক দেখতে হোভার করুন ➜
JDK 25+ →