Làm thế nào để tắt tất cả các Executors khi bỏ một ứng dụng?

Question

Theo đồng thời Java Goetz của Java trong thực tế JVM không thể thoát cho đến khi tất cả các chủ đề (nondaemon) đã chấm dứt, do đó, không đóng một Executor có thể ngăn chặn JVM thoát khỏi.

I.e. System.exit (0) không nhất thiết phải hoạt động như mong đợi nếu có Executors xung quanh. Có vẻ như cần thiết để đặt một số loại

public void stop() { exec.shutdown() } 

phương thức cho tất cả các lớp có chứa Executors, sau đó gọi cho chúng khi ứng dụng sắp kết thúc. Đây có phải là cách duy nhất, hoặc là có một số loại phím tắt để tắt tất cả các Executors?

Answer 1

Không có lối tắt nào để thực hiện tất cả, không. Ngoài ra, có thể bạn nên gọi shutdownNow() thay vì shutdown(), nếu không bạn có thể chờ một lúc.

Những gì bạn có thể làm, tôi giả sử, là khi bạn tạo Executor, hãy đăng ký nó ở vị trí trung tâm. Sau đó, khi tắt, chỉ cần gọi shutdown() trên đối tượng trung tâm đó, từ đó có thể chấm dứt từng người thực thi đã đăng ký.

Nếu bạn sử dụng Spring, thì bạn có thể tận dụng lợi thế của các hạt của nhà máy tạo và quản lý các Executors cho bạn. Điều đó bao gồm tắt chúng một cách duyên dáng khi ứng dụng thoát và giúp bạn tự quản lý chúng.

Answer 2

Có thể anh ta muốn nói rằng JVM không thể tự mình dừng lại cho đến khi chuỗi nondaemon kết thúc. Nó giống như chạy một lớp đơn giản từ lệnh như java SomeClass và sau khi thực thi phương thức main JVM dừng lại.

System.exit là lệnh chấm dứt JVM, ngay cả khi chuỗi chủ đề đang chạy JVM sẽ tắt.

Answer 3

Bạn cũng có thể cung cấp việc triển khai ThreadFactory đánh dấu các chủ đề đã tạo thành các chuỗi daemon. Tôi thích một cơ chế tắt máy sạch (với các phương pháp vòng đời) nhưng có những trường hợp bạn không cần đảm bảo về trạng thái/hoàn thành nhiệm vụ chưa hoàn thành khi điều này có thể phù hợp.

Answer 4

Theo mặc định, Trình thực thi sẽ chỉ tạo chuỗi không phải daemon. Bạn có thể ghi đè điều đó bằng cách cung cấp cho Executor với ThreadFactory của riêng bạn. Dưới đây là một ví dụ:

class DaemonThreadFactory implements ThreadFactory { 
    public Thread newThread(Runnable r) { 
    Thread t = new Thread(r); 
    t.setDaemon(true); 
    return t; 
    } 
} 

Hãy thận trọng, tuy nhiên, vì JVM sẽ thoát ngay lập tức ngay cả khi những chủ đề đang bận rộn làm công việc hữu ích!

Answer 5

Trang trí người thi hành với com.google.common.util.concurrent.MoreExecutors#getExitingExecutorService

@Beta 
public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor, 
             long terminationTimeout, 
             TimeUnit timeUnit) 

Chuyển đổi ThreadPoolExecutor đưa vào một ExecutorService mà thoát khi ứng dụng hoàn tất. Nó làm như vậy bằng cách sử dụng các chủ đề daemon và thêm một hook shutdown để chờ đợi cho hoàn thành của họ.

Đây là chủ yếu cho các hồ bơi cố định. Xem Executors.newFixedThreadPool (int).