關閉ScheduledExecutorService安全嗎？

我正在實施一項服務，該服務執行一些較長時間運行的任務，此處由Thread.sleep(10000)模擬。當我按ctrl + c執行時，我從來沒有得到我期望的InterruptedException。我想知道爲什麼。關閉ScheduledExecutorService安全嗎？

package simple; 

import my.util.Now; 
import io.dropwizard.lifecycle.Managed; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 

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

public class EmailSender implements Managed { 

    private static final Logger LOGGER = LoggerFactory.getLogger(EmailSender.class); 
    ScheduledExecutorService executorService = Executors.newScheduledThreadPool(3); 

    // Constructor 
    public EmailSender() {} 

    @Override 
    public void start() { 
     LOGGER.info("Starting email sender thread: {}", Thread.currentThread().getName()); 
     Runnable task =() -> { 
      LOGGER.info("Running: {} in thread: {}", Now.now(), Thread.currentThread().getName()); 
      try { 
       Thread.sleep(10000); 
      } catch (InterruptedException ie) { 
       LOGGER.error("Task is being interrupted: {}", ie.getMessage()); 
      } 
     }; 
     executorService.scheduleAtFixedRate(task, 0, 5, TimeUnit.SECONDS); 
    } 

    @Override 
    public void stop() { 
     LOGGER.info("Stopping email sender thread: {}", Thread.currentThread().getName()); 
     executorService.shutdown(); 

    } 
}

這樣可以安全地假設executorService.shutdown();等到執行完成任務這樣嗎？

來源

2016-07-16 Istvan

該文檔基本上說明了一切：['關機（）']（https://docs.oracle.com/javase/7/ docs/api/java/util/concurrent/ExecutorService.html＃shutdown（））會阻止執行程序接受新的提交。您可能希望['shutdownNow（）']（https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#shutdownNow（）），它會中斷正在運行的線程。不，後者是不安全的，因爲中斷線程不是很安全。 – dhke

shutdown不會終止正在運行的任務，它甚至會執行在隊列中等待的任務。

如果您想立即終止，請使用shutdownNow。

來源

2016-07-16 09:34:52

這是安全的假設executorService.shutdown（）;這樣等待執行完成任務嗎？

不會。它不會等待所有線程完成。從ExecutorService Oracle文檔頁面

推薦方式：

void shutdownAndAwaitTermination(ExecutorService pool) { 
    pool.shutdown(); // Disable new tasks from being submitted 
    try { 
    // Wait a while for existing tasks to terminate 
    if (!pool.awaitTermination(60, TimeUnit.SECONDS)) { 
     pool.shutdownNow(); // Cancel currently executing tasks 
     // Wait a while for tasks to respond to being cancelled 
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) 
      System.err.println("Pool did not terminate"); 
    } 
    } catch (InterruptedException ie) { 
    // (Re-)Cancel if current thread also interrupted 
    pool.shutdownNow(); 
    // Preserve interrupt status 
    Thread.currentThread().interrupt(); 
    }

shutdown():發起在以前已提交任務的執行一個有序的關閉，但沒有新的任務將被接受。

shutdownNow():嘗試停止所有正在執行的任務，停止等待任務的處理並返回正在等待執行的任務的列表。

您可以更改

if (!pool.awaitTermination(60, TimeUnit.SECONDS))

到

while (!pool.awaitTermination(60, TimeUnit.SECONDS)) 
Thread.sleep(60000);

來源

2016-07-16 14:45:26

關閉ScheduledExecutorService安全嗎？

回答

相關問題