El Java ExecutorService és la interfície que ens permet executar tasques en fils de manera asíncrona. La interfície Java ExecutorService està present al paquet java.util.concurrent. L'ExecutorService ajuda a mantenir un conjunt de fils i els assigna tasques. També ofereix la possibilitat de posar en cua les tasques fins que hi hagi un fil lliure disponible si el nombre de tasques és superior als fils disponibles.

Mètodes de Java ExecutorService

Un programa senzill de 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(); } } 

Sortida:

En aquest programa, estem creant un ExecutorService amb deu fils i assignant-li una implementació executable anònima que realitza una tasca per imprimir 'ExecutorService' i un cop finalitzada la seva tasca, tanquem el servei executor.

Com utilitzar Java ExecutorService

Instanciació d'ExecutorService

Podem utilitzar Java ExecutorService per crear un únic fil, un grup de fils o un grup de fils programat. La classe Executors proporciona mètodes de fàbrica per crear una instancia d'un ExecutorService de la següent manera:

 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. 

Assignació de tasques a ExecutorServices

Per assignar una tasca a ExecutorService, podem utilitzar els mètodes següents:

• executar (tasca executable)
• enviar (tasca que es pot executar) / enviar (tasca que es pot cridar)
• invokeAny(Col·lecciótasques)
• invokeAll(Col·lecciótasques)

Exemple d'assignació d'una tasca a ExecutorService mitjançant el mètode execute().

El mètode execute() del Java ExecutorService incorpora un objecte executable i realitza la seva tasca de manera asíncrona. Després de fer la crida al mètode d'execució, anomenem el mètode d'apagada, que bloqueja qualsevol altra tasca per posar en cua a 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(); } } 

Sortida:

 ExecutorService 

Exemple d'assignació d'una tasca a ExecutorService mitjançant submit()

El mètode submit() agafa un objecte executable i retorna un objecte Future. Aquest objecte s'utilitza més tard per comprovar l'estat de Runnable si s'ha completat l'execució o no.

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

Exemple d'assignació d'una tasca a ExecutorService mitjançant el mètode invokeAny().

El mètode invokeAny() pren una col·lecció d'objectes Callablle o objectes de classes que implementen Callable. Aquest mètode retorna l'objecte futur de l'objecte cridable que s'executa amb èxit primer.

 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>

Sortida:

 result = Task 1 

El resultat emmagatzema la tasca 1 ja que primer s'executa correctament el primer objecte cridable.

Exemple d'assignació d'una tasca a ExecutorService mitjançant el mètode invokeAll().

El mètode invokeAll() recull una col·lecció d'objectes cridables amb tasques i retorna una llista d'objectes futurs que conté el resultat de totes les tasques.

 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>

Sortida:

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

Com tancar l'ExecutorService

Un cop acabem amb les nostres tasques assignades a ExecutorService, haurem de tancar-lo perquè ExecutorService realitza la tasca en diferents fils. Si no tanquem l'ExecutorService, els fils continuaran funcionant i la JVM no s'aturarà.

El procés de tancament es pot fer mitjançant els tres mètodes següents:

• mètode shutdown().
• mètode shutdownNow().
• Mètode awaitTermination().