shutdown và awaitTermination mà cuộc gọi đầu tiên có bất kỳ sự khác biệt?

Question

sự khác biệt giữa

ExecutorService eService = Executors.newFixedThreadPool(2); 
eService.execute(new TestThread6()); 
eService.execute(new TestThread6()); 
eService.execute(new TestThread6()); 
eService.awaitTermination(1, TimeUnit.NANOSECONDS); 
eService.shutdown(); 

và

eService.shutdown(); 
eService.awaitTermination(1, TimeUnit.NANOSECONDS); 

Tôi không thực sự hiểu shutdown() là gì. Phương thức này không chờ đợi các tác vụ được gửi trước đó để hoàn thành việc thực hiện. Có nghĩa là shutdown() có thể chấm dứt các tác vụ đã được gửi, nhưng chưa hoàn thành? Tôi đã thử một số ví dụ, họ không chứng minh điều đó, xin vui lòng cho tôi một ví dụ.

Answer 1

Trước tiên, bạn nên gọi số shutdown. Nếu không, bạn có thể chờ đợi một thời gian rất dài, vì awaitTermination không thực sự tắt máy thực thi của bạn.

Nếu bạn muốn đợi các tác vụ hoàn tất, thay vì đợi cho người thực hiện tắt, thì bạn nên sử dụng invokeAll.

Answer 2

Sau khi chúng tôi bắt đầu tác vụ đầu tiên ThreadPoolExecutor sẽ bắt đầu một chuỗi sẽ không kết thúc ngay cả sau khi tác vụ được hoàn tất. Ít nhất nó là đúng cho một hồ bơi cố định thread. Đây là lý do tại sao chúng ta cần phải gọi tắt máy. Sau khi tắt ThreadPoolExecutor sẽ từ chối bất kỳ nhiệm vụ mới nhưng sẽ chờ đợi cho các nhiệm vụ đang chạy để kết thúc và sau đó cho phép các Threads kết thúc. Đây là lý do tại sao chúng tôi cần awaitTermination sau khi shutdwon.

Answer 3

shutdown nghĩa là dịch vụ thực thi không còn tác vụ đến nào nữa.

awaitTermination được gọi sau khi yêu cầu tắt máy.

Trước tiên, bạn cần phải tắt dịch vụ và sau đó chặn và chờ chủ đề kết thúc.

Nếu bạn muốn xem tất cả các chủ đề kết thúc chạy và nhấn mạnh vào việc sử dụng awaiTermination, bạn cần đặt thông số hết thời gian chờ đủ lớn. Vì vậy, bạn có thể làm:

eService.shutdown(); 
if (!eService.awaitTermination(60000, TimeUnit.SECONDS)) 
    System.err.println("Threads didn't finish in 60000 seconds!"); 
} 

Ngoài ra, bạn có thể làm:

eService.shutdown(); 
while (!eService.isTerminated()) { 

} 

Bằng cách này bạn có thể để đảm bảo tất cả các chủ đề đã kết thúc chạy, trừ khi họ bị gián đoạn bất ngờ.

Answer 4

Đọc tài liệu hướng dẫn luôn giúp:

shutdownNow:

nỗ lực để ngăn chặn tất cả các nhiệm vụ chủ động thực hiện, tạm dừng việc xử lý của nhiệm vụ chờ đợi, và trả về một danh sách các nhiệm vụ đã được chờ đợi thực thi. Các tác vụ này được rút ra (bị xóa) khỏi hàng đợi nhiệm vụ khi trở về từ phương thức này.

Phương thức này không chờ đợi cho các tác vụ thực thi tích cực chấm dứt. Sử dụng awaitĐiều chỉnh để thực hiện điều đó.

Không có đảm bảo nào ngoài nỗ lực hết sức nỗ lực để ngừng xử lý chủ động thực hiện các tác vụ. Triển khai này hủy nhiệm vụ qua Chủ đề.gián đoạn(), vì vậy bất kỳ nhiệm vụ nào không đáp ứng với ngắt có thể không bao giờ chấm dứt

shutdown:

Ðồng một trật tự tắt máy, trong đó nhiệm vụ đệ trình trước đây là thực hiện, nhưng không mới nhiệm vụ sẽ được chấp nhận. Yêu cầu không có hiệu ứng bổ sung nếu đã tắt.

Phương pháp này không chờ cho các tác vụ được gửi trước đây để hoàn thành việc thực thi . Sử dụng awaitTermination để làm điều đó.

awaitTermination:

Blocks cho đến khi tất cả các nhiệm vụ đã hoàn thành thi công sau khi một yêu cầu tắt máy, hoặc thời gian chờ xảy ra, hoặc các chủ đề hiện hành bị gián đoạn, nào đến trước.

Answer 5

Bạn cần gọi phương thức shutdownNow() sau khi cuộc gọi phương thức awaitTermination() đã xảy ra. Sau đó, chỉ bạn mới có thể tìm hiểu cách sử dụng thực tế của phương thức awaitTermination()