Java ExecutorService, iş parçacığı üzerindeki görevleri eşzamansız olarak yürütmemize olanak sağlayan arayüzdür. Java ExecutorService arayüzü java.util.concurrent paketinde mevcuttur. ExecutorService, bir iş parçacığı havuzunun korunmasına yardımcı olur ve onlara görevler atar. Ayrıca, görev sayısı mevcut iş parçacığından fazlaysa, boş bir iş parçacığı bulunana kadar görevleri sıraya koyma olanağı da sağlar.

işaretleme dipnotları

Java ExecutorService Yöntemleri

Basit bir Java ExecutorService programı

 public class ExecutorServiceExample { public static void main(String[] args) { ExecutorService executorService = Executors.newFixedThreadPool(10); executorService.execute(new Runnable() { @Override public void run() { System.out.println('ExecutorService'); } }); executorService.shutdown(); } } 

Çıktı:

Bu programda on thread'li bir ExecutorService oluşturup ona 'ExecutorService' yazdırmak için bir görev gerçekleştiren anonim çalıştırılabilir bir uygulama atadık ve görevi bittikten sonra executor servisini kapatıyoruz.

Java ExecutorService nasıl kullanılır?

ExecutorService'in Örneklenmesi

Tek bir iş parçacığı, bir iş parçacığı havuzu veya zamanlanmış bir iş parçacığı havuzu oluşturmak için Java ExecutorService'i kullanabiliriz. Executors sınıfı, bir ExecutorService örneğini oluşturmak için aşağıdaki gibi fabrika yöntemleri sağlar:

 ExecutorService executorService1 = Executors.newSingleThreadExecutor(); //Creates //a ExecutorService object having a single thread. ExecutorService executorService2 = Executors.newFixedThreadPool(10); // Creates a //ExecutorService object having a pool of 10 threads. ExecutorService executorService3 = Executors.newScheduledThreadPool(10); //Creates a scheduled thread pool executor with 10 threads. In scheduled thread //pool, we can schedule tasks of the threads. 

ExecutorServices'e görev atama

ExecutorService'e bir görev atamak için aşağıdaki yöntemleri kullanabiliriz:

• yürüt(Çalıştırılabilir görev)
• gönder(Çalıştırılabilir görev) / gönder(Çağrılabilir görev)
• invokeAny(Koleksiyongörevler)
• invokeAll(Koleksiyongörevler)

Yürütme() yöntemini kullanarak ExecutorService'e görev atama örneği

Java ExecutorService'in executive() yöntemi çalıştırılabilir bir nesneyi alır ve görevini eşzamansız olarak gerçekleştirir. Yürütme yöntemini çağırdıktan sonra, executorService'de diğer görevlerin sıraya girmesini engelleyen kapatma yöntemini çağırıyoruz.

 public class ExecutorServiceExample { public static void main(String[] args) { ExecutorService executorService = Executors.newSingleThreadExecutor(); executorService.execute(new Runnable() { @Override public void run() { System.out.println('ExecutorService'); } }); executorService.shutdown(); } } 

Çıktı:

 ExecutorService 

Submit() kullanarak ExecutorService'e görev atama örneği

submit() yöntemi çalıştırılabilir bir nesneyi alır ve bir Future nesnesi döndürür. Bu nesne daha sonra Runnable'ın yürütmeyi tamamlayıp tamamlamadığını kontrol etmek için kullanılır.

 public class ExecutorServiceExample { public static void main(String[] args) { ExecutorService executorService = Executors.newSingleThreadExecutor(); executorService.submit(new Runnable() { @Override public void run() { System.out.println('ExecutorService'); } }); } } 

invokeAny() yöntemini kullanarak ExecutorService'e görev atama örneği

java xor

invokeAny() yöntemi, Callable nesnelerinden veya Callable'ı uygulayan sınıf nesnelerinin bir koleksiyonunu alır. Bu yöntem, ilk önce başarıyla yürütülen çağrılabilir nesnenin gelecekteki nesnesini döndürür.

 public class ExecutorServiceExample { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executorService = Executors.newSingleThreadExecutor(); Set<callable> callables = new HashSet<callable>(); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 1&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 2&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 3&apos;; } }); String result = executorService.invokeAny(callables); System.out.println(&apos;result = &apos; + result); executorService.shutdown(); } } </callable></callable>

Çıktı:

 result = Task 1 

Sonuç, ilk çağrılabilir nesnenin başarıyla yürütülmesi nedeniyle Görev 1'i depolar.

invokeAll() yöntemini kullanarak ExecutorService'e görev atama örneği

invokeAll() yöntemi, görevleri olan Çağrılabilir nesnelerin bir Koleksiyonunu alır ve tüm görevlerin sonucunu içeren Future nesnelerinin bir listesini döndürür.

 public class ExecutorServiceExample { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executorService = Executors.newSingleThreadExecutor(); Set<callable> callables = new HashSet<callable>(); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 1&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 2&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 3&apos;; } }); java.util.List<future> futures = executorService.invokeAll(callables); for(Future future : futures){ System.out.println(&apos;future.get = &apos; + future.get()); } executorService.shutdown(); } } </future></callable></callable>

Çıktı:

 future.get = Task 1 future.get = Task 3 future.get = Task 2 

ExecutorService nasıl kapatılır

ExecutorService’e verdiğimiz görevlerimiz bitince onu kapatmak zorunda kalıyoruz çünkü ExecutorService görevi farklı thread’lerde gerçekleştiriyor. ExecutorService'i kapatmazsak iş parçacıkları çalışmaya devam edecek ve JVM kapanmayacaktır.

Kapatma işlemi aşağıdaki üç yöntemle yapılabilir:

• kapatma() yöntemi
• kapatmaŞimdi() yöntemi
• waitTermination() yöntemi