CodeBlanks Logo Icon CodeBlanks
Giriş Yap Kayıt Ol

CompletableFuture

CompletableFuture ile asenkron zincirleri öğrenirsin.

CompletableFuture

CompletableFuture, asenkron işlemleri zincirleme ve birleştirme imkanı sunar. supplyAsync bir görevi havuzda çalıştırır; thenApply, thenAccept gibi yöntemler sonuç üzerinde sıradaki adımı tanımlar.

CompletableFuture<Integer> f =
    CompletableFuture.supplyAsync(() -> 2 + 3)
                     .thenApply(n -> n * 2);
System.out.println(f.join());  // 10

join() sonucu bekler; get()'ten farklı olarak kontrollü istisna fırlatır. Bu, fonksiyonel stilde asenktron akışlar kurmayı kolaylaştırır. Birden çok future'ı allOf ile birleştirebilirsin.

allOf ile birleştirme

Birden çok future'ı paralel çalıştırmak ve hepsinin bitmesini beklemek için allOf kullanılır. Bu, bağımsız görevleri hızlandırmak için idealdir.

CompletableFuture<Void> all = CompletableFuture.allOf(f1, f2);
all.join();
// f1 ve f2 tamamlandı

Buradan sonra her future'ın sonucu f1.join() ile alınır. Bu, paralel API istekleri gibi senaryolarda verimi artırır. anyOf ise en erken biteni döndürür. Bu, modern asenktron Java kodunun temelidir.

Uygulama CompletableFuture zinciri kur

Bir AsyncDemo sınıfında main yaz; CompletableFuture.supplyAsync(() -> 10) ile başla, .thenApply(n -> n + 5) ile 15 üret ve System.out.println(f.join()) ile sonucu yazdır.

Başlangıç kodu

Main.java
import java.util.concurrent.*;

// AsyncDemo sınıfında main yaz

// supplyAsync ile 10 döndüren görevi başlat; thenApply ile 5 ekle; join ile yazdır

Örnek çözüm

Main.java
import java.util.concurrent.*;

class AsyncDemo {
    public static void main(String[] args) {
        CompletableFuture<Integer> f =
            CompletableFuture.supplyAsync(() -> 10).thenApply(n -> n + 5);
        System.out.println(f.join());
    }
}

Beklenen çıktı

15

Soru ve cevaplar

Dersin sorularını cevaplarıyla birlikte inceleyebilirsin. Kendini denemek istersen dersi interaktif olarak çöz.

1 CompletableFuture yöntemlerini eşleştir

Kavram Anlamı
supplyAsync Görevi havuzda çalıştırır
thenApply Sonucu dönüştürür
thenAccept Sonucu tüketir
join Sonucu bekler

2 thenApply çağrısını tamamla

Soru 
CompletableFuture.supplyAsync(() -> 2 + 3)
    .____(n -> n * 2);
Cevap 
CompletableFuture.supplyAsync(() -> 2 + 3)
    .thenApply(n -> n * 2);

Açıklama: thenApply sonucu dönüştürür.

3 CompletableFuture.join() ne döndürür?

  • Future'ı iptal eder
  • Sonucu bekleyip döndürür Doğru cevap
  • Hemen void
  • Yeni bir future oluşturur

Açıklama: join() sonucu bekleyip döndürür.

İleri seviye bölümündeki tüm dersler

1 Stream ileri

  1. collect groupingBy
  2. partitioningBy
  3. joining
  4. reduce
  5. flatMap
  6. Özet - Stream ileri

2 Optional

  1. Optional.of
  2. ofNullable
  3. map ve flatMap
  4. orElse ve orElseGet
  5. ifPresent ve isPresent
  6. Özet - Optional

3 Functional interface

  1. Function<T,R>
  2. Predicate<T>
  3. Consumer<T>
  4. Supplier<T>
  5. @FunctionalInterface
  6. Özet - Functional interface

4 Date/time API

  1. LocalDate
  2. LocalTime ve LocalDateTime
  3. Duration ve Period
  4. DateTimeFormatter
  5. Instant ve ZonedDateTime
  6. Özet - Date/time API

5 Reflection

  1. Class<?>
  2. getFields
  3. getMethods
  4. invoke
  5. getDeclaredConstructors
  6. Özet - Reflection

6 Annotation

  1. Yerleşik annotation'lar
  2. @interface
  3. Retention ve Target
  4. Annotation değerleri
  5. Reflection ile annotation
  6. Özet - Annotation

7 Tasarım desenleri

  1. Singleton
  2. Factory
  3. Strategy
  4. Observer
  5. Decorator
  6. Özet - Tasarım desenleri

8 JUnit test

  1. JUnit temelleri
  2. Assertions
  3. @BeforeEach ve @AfterEach
  4. @ParameterizedTest
  5. @DisplayName
  6. Özet - JUnit test

9 Mockito

  1. Mock
  2. @Mock
  3. when thenReturn
  4. verify
  5. ArgumentMatchers
  6. Özet - Mockito

10 Multithreading

  1. Thread
  2. Runnable
  3. start ve join
  4. synchronized
  5. wait ve notify
  6. Özet - Multithreading

11 Concurrent API

  1. ExecutorService
  2. Callable ve Future
  3. CompletableFuture
  4. ConcurrentHashMap
  5. Lock ve Condition
  6. Özet - Concurrent API

12 I/O ve NIO temelleri

  1. Path
  2. Files
  3. readString ve writeString
  4. Buffered I/O
  5. Channels
  6. Özet - I/O ve NIO temelleri

13 İleri proje

  1. Proje tasarımı
  2. Stream katmanı
  3. Concurrent katmanı
  4. Test katmanı
  5. Birleştirme

14 İleri seviye finali

  1. Proje tasarımı
  2. Stream katmanı
  3. Concurrent katmanı
  4. Reflection ve annotation
  5. Birleştirme