Tại sao Executors.newCachedThreadPool ném java.util.concurrent.RejectedExecutionException trong khi gửi

Question

Số lượng tác vụ (chủ đề) được gửi cũng không lớn trong kịch bản thử nghiệm này.

Answer 1

Bạn sẽ cần phải cung cấp mẫu mã như thế nào bạn nhanh chóng và gọi submit trên hồ bơi (IP nên một tổ chức phi Vấn đề ở đây là chúng ta không cần chi tiết của ruột của Callable lớp hoặc bất cứ điều gì giống như của bạn cái đó).

Dựa trên thông tin bạn đã cung cấp, bạn gần như chắc chắn sẽ tắt dịch vụ thực thi ở đâu đó trước khi gửi cuộc gọi đến nó. Kiểm tra xem bạn có thực hiện bất kỳ cuộc gọi nào tới shutdown hoặc shutdownNow và nếu như vậy đảm bảo rằng bạn không thêm công việc sau thời điểm này.

Ngoài ra, bạn có thể muốn đăng ký triển khai của riêng mình java.util.concurrent.RejectedExecutionHandler để hỗ trợ gỡ lỗi; thông điệp rejectedExecution của nó sẽ được gọi bất cứ khi nào người thi hành không thể chấp nhận một nhiệm vụ, vì vậy bạn có thể đặt một số logic kiểm tra trạng thái thô sơ ở đó để giúp bạn tìm ra nguyên nhân.

Answer 2

Tôi không thấy bất cứ nơi nào trong yêu cầu của các phương pháp Executors.newCachedThreadPool() trong đó RejectedExecutionException bị ném. Chỉ có ba trường hợp nó dường như được ném trong Java 6:

• khi gọi execute() trên ThreadPoolExecutor và kích thước hồ bơi tối đa đã đạt tới.
• khi gọi execute() trên số ThreadPoolExecutor cùng lúc với shutdownNow và về cơ bản đã bị mất cuộc đua với cuộc gọi shutdownNow.
• khi cố gắng lên lịch thực hiện một lần chạy trong một ScheduledThreadPoolExecutor sau khi người thực hiện đã bị tắt.