Java ExecutorService on käyttöliittymä, jonka avulla voimme suorittaa tehtäviä säikeissä asynkronisesti. Java ExecutorService -käyttöliittymä on java.util.concurrent-paketissa. ExecutorService auttaa ylläpitämään lankavarastoa ja määrittää niille tehtäviä. Se tarjoaa myös mahdollisuuden asettaa tehtäviä jonoon, kunnes vapaata säiettä on saatavilla, jos tehtäviä on enemmän kuin käytettävissä olevia säikeitä.

Java ExecutorServicen menetelmät

Yksinkertainen Java ExecutorServicen ohjelma

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

Lähtö:

Tässä ohjelmassa luomme kymmenen säikeen ExecutorServicen ja määritämme sille anonyymin suoritettavan toteutuksen, joka suorittaa tehtävän tulostaa 'ExecutorService' ja kun sen tehtävä on ohi, suljemme executor-palvelun.

Java ExecutorServicen käyttäminen

Instantiating ExecutorService

Voimme käyttää Java ExecutorServiceä luodaksesi yhden säikeen, säikeiden joukon tai ajoitetun säikeen poolin. Executors-luokka tarjoaa tehdasmenetelmiä ExecutorServicen luomiseksi seuraavasti:

 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. 

Tehtävien osoittaminen ExecutorServicesille

Voit määrittää tehtävän ExecutorServicelle käyttämällä seuraavia menetelmiä-

• suorita (suoritettava tehtävä)
• lähetä (suoritettava tehtävä) / lähetä (kutsuttava tehtävä)
• invokeAny(kokoelmatehtävät)
• invokeAll(kokoelmatehtävät)

Esimerkki tehtävän määrittämisestä ExecutorServicelle käyttämällä execute()-metodia

Java ExecutorServicen execute()-metodi ottaa vastaan ​​suoritettavan objektin ja suorittaa tehtävänsä asynkronisesti. Suorituskutsun jälkeen kutsumme shutdown-menetelmää, joka estää muita tehtäviä joutumasta executorServicen jonoon.

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

Lähtö:

 ExecutorService 

Esimerkki tehtävän määrittämisestä ExecutorServicelle käyttämällä submit()

Submit()-metodi ottaa vastaan ​​suoritettavan objektin ja palauttaa Future-objektin. Tätä objektia käytetään myöhemmin tarkistamaan Runnable-tiedoston tila, onko se suoritettu loppuun vai ei.

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

Esimerkki tehtävän määrittämisestä ExecutorServicelle käyttämällä invokeAny()-metodia

InvokeAny()-metodi ottaa Callablle-objektien tai Callable-sovelluksen toteuttavien luokkien objektit. Tämä menetelmä palauttaa kutsuttavan objektin tulevan objektin, joka suoritetaan onnistuneesti ensin.

 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>

Lähtö:

 result = Task 1 

Tulos tallentaa tehtävän 1, koska ensimmäinen kutsuttava objekti suoritetaan onnistuneesti ensin.

Esimerkki tehtävän määrittämisestä ExecutorServicelle käyttämällä invokeAll()-metodia

Metodi invokeAll() ottaa kokoelman kutsuttavia objekteja, joissa on tehtäviä, ja palauttaa luettelon tulevista objekteista, joka sisältää kaikkien tehtävien tuloksen.

 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>

Lähtö:

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

Kuinka sammuttaa ExecutorService

Kun olemme saaneet valmiiksi ExecutorServicelle annetut tehtävämme, meidän on suljettava se, koska ExecutorService suorittaa tehtävän eri säikeissä. Jos emme sulje ExecutorServiceä, säikeet jatkavat toimintaansa ja JVM ei sammu.

Sammutusprosessi voidaan tehdä seuraavilla kolmella tavalla:

• shutdown() -menetelmä
• shutdownNow() -menetelmä
• awaitTermination() -menetelmä