CodeBlanks Logo Icon CodeBlanks
Giriş Yap Kayıt Ol

Özet - Concurrent API

ExecutorService ve CompletableFuture'i birleştirerek paralel bir indirme yazarsın.

Özet - Concurrent API

Bu grupta java.util.concurrent'in temel araçlarını gördün: ExecutorService ile havuz, Callable ve Future ile sonuç, CompletableFuture ile zincir, ConcurrentHashMap ile güvenli harita ve Lock ile esnek kilitleme. Bu araçlar, modern eşzamanlı Java kodunun temelini oluşturur.

Şimdi bunları bir mini göreve birleştireceksin: paralel görevler yürüten bir ParallelSum yapısı kuracaksın. Bu özet, eşzamanlı kodun nasıl modüler biçimde yazıldığını gösterir.

Uygulama ParallelSum ile iki görevi topla

Bir ParallelSum sınıfında main yaz; Executors.newFixedThreadPool(2) ile havuz oluştur. İki Callable<Integer> görevi tanımla: biri () -> 10, diğeri () -> 20. İkisini submit ile havuza ver; get() ile sonuçları al; topla ve yazdır. shutdown() çağır.

Başlangıç kodu

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

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

// newFixedThreadPool(2) ile havuz oluştur; iki Callable submit et; get ile topla; shutdown

Örnek çözüm

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

class ParallelSum {
    public static void main(String[] args) throws Exception {
        ExecutorService pool = Executors.newFixedThreadPool(2);
        Future<Integer> a = pool.submit(() -> 10);
        Future<Integer> b = pool.submit(() -> 20);
        System.out.println(a.get() + b.get());
        pool.shutdown();
    }
}

Beklenen çıktı

30

Uygulama CompletableFuture ile zincir

Yeni bir ChainDemo sınıfında main yaz; CompletableFuture.supplyAsync(() -> "hi") ile başla, .thenApply(s -> s.toUpperCase()) ile sonucu büyüt ve System.out.println(f.join()) ile yazdır.

Başlangıç kodu

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

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

// supplyAsync ile "hi" döndür; thenApply ile büyük harfe çevir; join ile yazdır

Örnek çözüm

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

class ChainDemo {
    public static void main(String[] args) {
        CompletableFuture<String> f =
            CompletableFuture.supplyAsync(() -> "hi").thenApply(s -> s.toUpperCase());
        System.out.println(f.join());
    }
}

Beklenen çıktı

HI

Soru ve cevaplar

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

1 Bir görevin sonucunu beklemek için en uygun yöntem ne?

  • Thread.sleep()
  • Thread.yield()
  • Object.wait()
  • Future.get() Doğru cevap

Açıklama: Future.get() görev bitene kadar bekler.

2 Concurrent API özetini eşleştir

Kavram Anlamı
ExecutorService Havuz yönetir
Future Sonucu bekler
CompletableFuture Zincir kurar
Lock Esnek kilit

İ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