Java ExecutorService er grænsefladen, som giver os mulighed for at udføre opgaver på tråde asynkront. Java ExecutorService-grænsefladen er til stede i pakken java.util.concurrent. ExecutorService hjælper med at vedligeholde en pulje af tråde og tildeler dem opgaver. Det giver også mulighed for at stille opgaver i kø, indtil der er en ledig tråd tilgængelig, hvis antallet af opgaver er mere end de tilgængelige tråde.

Metoder til Java ExecutorService

Et simpelt program af Java ExecutorService

 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(); } } 

Produktion:

homogen blanding

I dette program opretter vi en ExecutorService med ti tråde og tildeler den en anonym kørselsimplementering, som udfører en opgave for at udskrive 'ExecutorService', og efter dens opgave er overstået, lukker vi executor-tjenesten ned.

Sådan bruger du Java ExecutorService

Instantiating ExecutorService

Vi kan bruge Java ExecutorService til at oprette en enkelt tråd, en pool af tråde eller en planlagt pool af tråde. Executors-klassen giver fabriksmetoder til at instansiere en ExecutorService som følger-

 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. 

Tildeling af opgaver til ExecutorServices

For at tildele en opgave til ExecutorService kan vi bruge følgende metoder-

• execute (kørbar opgave)
• submit(Kørbar opgave) / submit(Opkaldbar opgave)
• invokeAny(Collectionopgaver)
• invokeAll(Samlingopgaver)

Eksempel på tildeling af en opgave til ExecutorService ved hjælp af execute()-metoden

Java ExecutorServices execute()-metode tager et kørselbart objekt ind og udfører dets opgave asynkront. Efter at have foretaget opkaldet til execute-metoden, kalder vi shutdown-metoden, som blokerer enhver anden opgave for at stå i kø i executorService.

 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(); } } 

Produktion:

 ExecutorService 

Eksempel på tildeling af en opgave til ExecutorService ved hjælp af submit()

Submit()-metoden tager et kørselbart objekt ind og returnerer et Future-objekt. Dette objekt bruges senere til at kontrollere status for Runnable, uanset om det har fuldført eksekvering eller ej.

 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'); } }); } } 

Eksempel på tildeling af en opgave til ExecutorService ved hjælp af metoden invokeAny().

strengmetoder i java

Metoden invokeAny() tager en samling af Callablle-objekter eller objekter af klasser, der implementerer Callable. Denne metode returnerer det fremtidige objekt for det kaldbare objekt, som bliver udført først.

 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>

Produktion:

 result = Task 1 

Resultatet gemmer opgave 1, da det første kaldbare objekt udføres først.

Eksempel på tildeling af en opgave til ExecutorService ved hjælp af metoden invokeAll().

Metoden invokeAll() tager en samling af Callable-objekter med opgaver ind og returnerer en liste over Future-objekter, der indeholder resultatet af alle opgaverne.

 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>

Produktion:

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

Sådan lukker du ExecutorService

Når vi er færdige med vores opgaver givet til ExecutorService, så er vi nødt til at lukke den ned, fordi ExecutorService udfører opgaven på forskellige tråde. Hvis vi ikke lukker ExecutorService, vil trådene blive ved med at køre, og JVM'en lukker ikke ned.

Processen med at lukke ned kan udføres på følgende tre metoder-

• shutdown() metode
• shutdownNow() metode
• awaitTermination() metode