Interfaccia ExecutorService

Un'interfaccia java.util.concurrent.ExecutorService è una sottointerfaccia dell'interfaccia Executor e aggiunge funzionalità per gestire il ciclo di vita, sia delle singole attività che dell'esecutore stesso.

Metodi ExecutorService

Sr.No.	Metodo e descrizione
1	boolean awaitTermination(long timeout, TimeUnit unit) Si blocca fino a quando tutte le attività non hanno completato l'esecuzione dopo una richiesta di arresto, o si verifica il timeout o il thread corrente viene interrotto, a seconda di cosa si verifica per prima.
2	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) Esegue le attività date, restituendo un elenco di Futures che mantengono il loro stato e i risultati quando tutti sono stati completati.
3	<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) Esegue le attività date, restituendo un elenco di Futures che mantengono il loro stato e i risultati quando tutto è completato o il timeout scade, a seconda di cosa si verifica per prima.
4	<T> T invokeAny(Collection<? extends Callable<T>> tasks) Esegue i compiti dati, restituendo il risultato di uno che è stato completato con successo (cioè, senza lanciare un'eccezione), se ce ne sono.
5	<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) Esegue le attività date, restituendo il risultato di una che è stata completata con successo (cioè, senza lanciare un'eccezione), se ce ne sono prima che sia trascorso il timeout specificato.
6	boolean isShutdown() Restituisce vero se questo esecutore è stato chiuso.
7	boolean isTerminated() Restituisce vero se tutte le attività sono state completate dopo l'arresto.
8	void shutdown() Avvia un arresto ordinato in cui vengono eseguite le attività inoltrate in precedenza, ma non verranno accettate nuove attività.
9	List<Runnable> shutdownNow() Tenta di interrompere tutte le attività in esecuzione attiva, interrompe l'elaborazione delle attività in attesa e restituisce un elenco delle attività in attesa di esecuzione.
10	<T> Future<T> submit(Callable<T> task) Invia un'attività di restituzione del valore per l'esecuzione e restituisce un Future che rappresenta i risultati in sospeso dell'attività.
11	Future<?> submit(Runnable task) Invia un'attività eseguibile per l'esecuzione e restituisce un Future che rappresenta tale attività.
12	<T> Future<T> submit(Runnable task, T result) Invia un'attività eseguibile per l'esecuzione e restituisce un Future che rappresenta tale attività.

Esempio

Il seguente programma TestThread mostra l'utilizzo dell'interfaccia ExecutorService in un ambiente basato su thread.

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

public class TestThread {

   public static void main(final String[] arguments) throws InterruptedException {
      ExecutorService executor = Executors.newSingleThreadExecutor();

      try {
         executor.submit(new Task());
         System.out.println("Shutdown executor");
         executor.shutdown();
         executor.awaitTermination(5, TimeUnit.SECONDS);
      } catch (InterruptedException e) {
         System.err.println("tasks interrupted");
      } finally {

         if (!executor.isTerminated()) {
            System.err.println("cancel non-finished tasks");
         }
         executor.shutdownNow();
         System.out.println("shutdown finished");
      }
   }

   static class Task implements Runnable {
      
      public void run() {
         
         try {
            Long duration = (long) (Math.random() * 20);
            System.out.println("Running Task!");
            TimeUnit.SECONDS.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
   }	   
}

Questo produrrà il seguente risultato.

Produzione

Shutdown executor
Running Task!
shutdown finished
cancel non-finished tasks
java.lang.InterruptedException: sleep interrupted
	at java.lang.Thread.sleep(Native Method)
	at java.lang.Thread.sleep(Thread.java:302)
	at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:328)
	at TestThread$Task.run(TestThread.java:39)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)