Come fermare un ScheduledExecutorService?

Question

Il programma termina dopo nove stampe:

class BeeperControl { 

    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); 

    public void beep() { 
     final Runnable beeper = new Runnable() { 
      public void run() { 
       System.out.println("beep"); 
      } 
     }; 
     final ScheduledFuture<?> beeperHandle = scheduler.scheduleAtFixedRate(
       beeper, 1, 1, SECONDS); 
     scheduler.schedule(new Runnable() { 
      public void run() { 
       beeperHandle.cancel(true); 
      } 
     }, 1 * 9, SECONDS); 
    } 

    public static void main(String[] args) { 
     BeeperControl bc = new BeeperControl(); 
     bc.beep(); 
    } 
} 

Come fermare un processo (cioè processo java in Eclipse per esempio), perché non si ferma dopo un limite di tempo in 9 secondi?

Answer 1

Il problema che si verifica è che lo scheduler mantiene un thread attivo dopo aver annullato il task beep.

Se è presente un thread non daemon attivo, la JVM rimane attiva.

Il motivo che mantiene questa discussione intorno è che avete detto di farlo in questa linea:

private final ScheduledExecutorService scheduler 
     = Executors.newScheduledThreadPool(1); 

nota la documentazione di newScheduledThreadPool(int corePoolSize):

corePoolSize - il numero di thread tenere in piscina, anche se sono inattivo.

Quindi, avete due possibili modi per causare la JVM per terminare:

1. Passo 0 a newScheduledThreadPool invece di 1. Lo scheduler non manterrà un filo dal vivo, e la JVM terminerà.

2. Arresta il programma di pianificazione. Dovresti farlo comunque per liberare le sue risorse. Quindi cambiare il run nel vostro anonimo Runnable a:

   public void run() { 
       beeperHandle.cancel(true); 
       scheduler.shutdown(); 
   } 
   

(In realtà, non è necessario il cancel lì - il shutdown entrerà in vigore al più presto il prossimo "beep" è completata.)