Java Executor Service: Detaylı Anlatım

Java Executor Service: Detaylı Anlatım

Java’da paralel programlama, performans açısından büyük önem taşır. Birden fazla görevi eş zamanlı olarak yürütmek, uygulamaların hızlı ve verimli çalışmasını sağlar. Bu noktada, Executor Service devreye girer. Executor Service, thread yönetimini kolaylaştıran ve performansı optimize eden güçlü bir araçtır. Basitçe anlatmak gerekirse, bir thread havuzudur ve görevlerinizi bu havuzdaki işçilere (threads) dağıtır. Bu sayede thread oluşturma ve yönetimiyle uğraşmadan, işinize odaklanabilirsiniz.

Neden Executor Service Kullanmalıyız?

Standart thread oluşturma yöntemleri, çok sayıda görevin yönetimini zorlaştırır. Her görev için yeni bir thread oluşturmak, kaynak tüketimine ve performans düşüşüne yol açabilir. Executor Service ise bu sorunu, önceden tanımlanmış bir thread havuzu kullanarak çözer. Bu havuzdaki thread’ler tekrar kullanılabilir, dolayısıyla yeni thread oluşturma maliyetinden kurtulmuş oluruz. Ayrıca, Executor Service, thread’lerin yönetimini basitleştirerek, kodun daha okunaklı ve anlaşılır olmasını sağlar. Sonuç olarak, Executor Service ile daha verimli ve ölçeklenebilir uygulamalar geliştirebiliriz.

Executor Service’in Temel Bileşenleri

Executor Service, temel olarak üç ana bileşenden oluşur: ExecutorService arayüzü, ThreadPoolExecutor sınıfı ve çeşitli Factory metotları. ExecutorService arayüzü, thread’leri yönetmek için temel metotları tanımlar. ThreadPoolExecutor ise bu arayüzü uygulayan ve thread havuzunu yöneten bir sınıftır. Factory metotları ise önceden yapılandırılmış thread havuzları oluşturmayı kolaylaştırır.

ExecutorService Arayüzü

ExecutorService arayüzü, submit(), execute(), shutdown() gibi önemli metotları içerir. submit() metodu, bir görevi (Runnable veya Callable) havuzuna gönderir ve bir Future nesnesi döndürür. Bu nesne, görevin sonucunu veya durumunu sorgulamak için kullanılır. execute() metodu ise sadece görevi havuzuna gönderir. shutdown() metodu ise havuzun yeni görev kabul etmesini durdurur. Havuzdaki mevcut görevler tamamlandıktan sonra havuz kapatılır.

ThreadPoolExecutor Sınıfı

ThreadPoolExecutor sınıfı, thread havuzunun detaylı konfigürasyonunu sağlar. Thread sayısı, kuyruk boyutu, redaksiyon politikası gibi parametreler bu sınıf aracılığıyla ayarlanabilir. Örneğin, thread sayısını artırarak daha fazla görevi eş zamanlı olarak işleyebilir veya kuyruk boyutu artırılarak görevlerin birikmesini engelleyebilirsiniz. Yanlış yapılandırılmış bir ThreadPoolExecutor performans sorunlarına yol açabilir; bu yüzden dikkatli bir konfigürasyon önemlidir.

Factory Metotları

Executors sınıfı, önceden yapılandırılmış ExecutorService örnekleri oluşturmak için statik factory metotları sunar. Executors.newFixedThreadPool(), belirli sayıda thread’den oluşan sabit bir havuz oluşturur. Executors.newCachedThreadPool() ise gerektiğinde yeni thread’ler oluşturan ve kullanılmayan thread’leri geri dönüştüren bir havuz oluşturur. Executors.newSingleThreadExecutor(), tek bir thread ile çalışan bir havuz oluşturur. Doğru factory metodunu seçmek, uygulama gereksinimlerine bağlıdır.

Örnek Kod

Aşağıdaki örnek, Executors.newFixedThreadPool() kullanarak bir ExecutorService oluşturur ve beş görevi havuzuna gönderir:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5);

        for (int i = 0; i < 5; i++) {
            executor.execute(() -> {
                System.out.println("Görev " + Thread.currentThread().getName() + " çalışıyor.");
                // Görev işlemleri burada yapılır.
            });
        }

        executor.shutdown();
    }
}