Ana Sayfa / Streams / Sanal iş parçacığı yürütücüsü
Streams Orta

Sanal iş parçacığı yürütücüsü

Sınırsız hafif eşzamanlılık için sanal iş parçacığı yürütücülerini kullanın.

Kod Karşılaştırması
✕ Java 8 
ExecutorService exec =
    Executors.newFixedThreadPool(10);
try {
    futures = tasks.stream()
        .map(t -> exec.submit(t))
        .toList();
} finally {
    exec.shutdown();
}
✓ Java 21+ 
try (var exec = Executors
        .newVirtualThreadPerTaskExecutor()) {
    var futures = tasks.stream()
        .map(exec::submit)
        .toList();
}
Bu kodda bir sorun mu gördünüz? Bize bildirin.
Modern yöntem neden daha iyi
♾️

Boyutlandırma yok

Ayarlanacak havuz boyutu yok — gerektiği kadar iş parçacığı oluşturulabilir.

⚡

Hafif

Sanal iş parçacıkları MB değil, KB bellek kullanır.

🧹

Otomatik kapatma

try-with-resources kapatmayı otomatik olarak yönetir.

Eski Yaklaşım
Sabit İş Parçacığı Havuzu
Modern Yaklaşım
Sanal İş Parçacığı Yürütücüsü
JDK'dan itibaren
21
Zorluk
Orta
JDK Desteği
Sanal iş parçacığı yürütücüsü
Mevcut

JDK 21 LTS'den itibaren geniş çapta kullanılabilir (Eylül 2023)

Nasıl çalışır

Sanal iş parçacığı yürütücüsü her görev için yeni bir sanal iş parçacığı oluşturur. Havuz boyutlandırması gerekmez — sanal iş parçacıkları milyonlarca oluşturulabilecek kadar ucuzdur.

İlgili Belgeler
Executors.newVirtualThreadPerTaskExecutor() ↗ Virtual Threads (JEP 444) ↗
İlgili desenler
Streams İleri

Stream gatherers

Java 8
// Sliding window: manual implementation
List<List<T>> windows = new ArrayList<>();
for (int i = 0; i <= list.size()-3; i++) {
    windows.add(
        list.subList(i, i + 3));
}
Java 24+
var windows = stream
    .gather(
        Gatherers.windowSliding(3)
    )
    .toList();
Modernini görmek için üzerine gel ➜
JDK 24+ →
Streams Orta

Stream.iterate() with predicate

Java 8
Stream.iterate(1, n -> n * 2)
    .limit(10)
    .forEach(System.out::println);
// can't stop at a condition
Java 9+
Stream.iterate(
    1,
    n -> n < 1000,
    n -> n * 2
).forEach(IO::println);
// stops when n >= 1000
Modernini görmek için üzerine gel ➜
JDK 9+ →
Streams Başlangıç

Optional.ifPresentOrElse()

Java 8
Optional<User> user = findUser(id);
if (user.isPresent()) {
    greet(user.get());
} else {
    handleMissing();
}
Java 9+
findUser(id).ifPresentOrElse(
    this::greet,
    this::handleMissing
);
Modernini görmek için üzerine gel ➜
JDK 9+ →
Paylaş 𝕏 🦋 in ⬡