Làm thế nào để xử lý RejectedExecutionException với ThreadPoolExecutor trong java

Question

Cách tốt nhất để xử lý RejectedExecutionException trong khi sử dụng ThreadPoolExecutor trong Java là gì?

Tôi muốn đảm bảo rằng tác vụ được gửi không nên bỏ qua và chắc chắn sẽ được thực hiện. Hiện tại không có yêu cầu thời gian thực khó để hoàn thành nhiệm vụ.

Một trong những điều tôi nghĩ có thể được thực hiện là chờ đợi trong một vòng lặp cho đến khi tôi biết rằng có không gian trong hàng đợi runnable, và sau đó đi vào và thêm nó vào hàng đợi.

Sẽ rất vui nếu mọi người có thể chia sẻ trải nghiệm của họ.

Thêm giải pháp khả thi Tôi mặc dù:

while(executor.getQueue().remainingCapacity <= 0){ 
// keep looping 
Thread.sleep(100); 
}; 
//if the loop exits ,indicates that we have space in the queue hence 
//go ahead and add to the queue 
executor.execute(new ThreadInstance(params)); 

Answer 1

Tôi sẽ thay đổi hành vi của hàng đợi của bạn. ví dụ.

public class MyBlockingQueue<E> extends ArrayBlockingQueue<E> { 
    private final long timeoutMS; 

    public MyBlockingQueue(int capacity, long timeoutMS) { 
     super(capacity); 
     this.timeoutMS = timeoutMS; 
    } 

    @Override 
    public boolean offer(E e) { 
     try { 
      return super.offer(e, timeoutMS, TimeUnit.MILLISECONDS); 
     } catch (InterruptedException e1) { 
      Thread.currentThread().interrupt(); 
      return false; 
     } 
    } 
} 

Điều này sẽ chờ hàng đợi thoát ra trước khi bỏ cuộc.

Answer 2

Nếu bạn đã hạn chế hồ bơi thread của bạn để chỉ cho phép một số lượng nhất định của chủ đề đồng thời (thường là một điều tốt), sau đó ứng dụng cần bằng cách nào đó push- trở lại trên mã gọi, vì vậy khi bạn nhận được một RejectedExecutionException từ ThreadPoolExecutor bạn cần phải chỉ ra điều này cho người gọi và người gọi sẽ cần phải xử lý thử lại.

Tình huống tương tự là máy chủ web chịu tải nặng. Một khách hàng kết nối, máy chủ web phải trả lại 503 - Dịch vụ không có sẵn (thường là tình trạng tạm thời) và khách hàng quyết định phải làm gì với nó.