Ana Sayfa / Concurrency / wait/notify kuyruklarından BlockingQueue'ya
Concurrency Orta

wait/notify kuyruklarından BlockingQueue'ya

Elle yazılan üretici-tüketici koordinasyonunu BlockingQueue ile değiştirin.

Concurrency
Kod Karşılaştırması
✕ Manual wait and notify 
synchronized (queue) {
    while (queue.isEmpty()) {
        queue.wait();
    }
    Job job = queue.removeFirst();
    process(job);
}
✓ BlockingQueue 
BlockingQueue<Job> queue = new LinkedBlockingQueue<>();

Job job = queue.take();
process(job);
Bu kodda bir sorun mu gördünüz? Bize bildirin.
Modern yöntem neden daha iyi
🛡

Daha güvenli koordinasyon

Kuyruk kilitleme ve koşul sinyalleşmesini üstlenir.

👁

Net amaç

put() ve take() üretici-tüketici davranışını doğrudan ifade eder.

🎛

Yerleşik politikalar

Sınırlı kapasite, adalet, zaman aşımı veya bloklamayan işlemler seçin.

Eski Yaklaşım
Manuel wait ve notify
Modern Yaklaşım
BlockingQueue
JDK'dan itibaren
5
Zorluk
Orta
JDK Desteği
wait/notify kuyruklarından BlockingQueue'ya
Mevcut

JDK 5'ten (2004) itibaren geniş çapta kullanılabilir

Nasıl çalışır

Doğru wait/notify kodu, paylaşılan bir monitör, koşul döngüleri, eşleşen bildirimler ve dikkatli kesme (interrupt) işleme gerektirir. BlockingQueue bu kuralları kapsüller ve üretici-tüketici iş akışları için bloklayan, zaman aşımlı ve bloklamayan işlemler sunar. put() ve take() gibi çağrılar kesilebilir olmaya devam eder.

İlgili Belgeler
BlockingQueue ↗ LinkedBlockingQueue ↗
Kanıt
Kanıt kaynağını görüntüle ↗
İlgili desenler
Concurrency Başlangıç

ExecutorService auto-close

Java 8
ExecutorService exec =
    Executors.newCachedThreadPool();
try {
    exec.submit(task);
} finally {
    exec.shutdown();
    exec.awaitTermination(
        1, TimeUnit.MINUTES);
}
Java 19+
try (var exec =
        Executors.newCachedThreadPool()) {
    exec.submit(task);
}
// auto shutdown + await on close
Modernini görmek için üzerine gel ➜
JDK 19+ →
Concurrency İleri

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());
}
Modernini görmek için üzerine gel ➜
JDK 25+ →
Concurrency Başlangıç

Virtual threads

Java 8
Thread thread = new Thread(() -> {
    System.out.println("hello");
});
thread.start();
thread.join();
Java 21+
Thread.startVirtualThread(() -> {
    IO.println("hello");
}).join();
Modernini görmek için üzerine gel ➜
JDK 21+ →