Keep-alive hoạt động như thế nào với ThreadPoolExecutor?

Question

Khi tiếp tục với số question được đăng bởi tôi, tôi đang cố gắng sử dụng ThreadPoolExecutor trong codebase của mình. Ngay cả sau khi lặp đi lặp lại những nỗ lực để hiểu từ tài liệu API Java, tôi đã không hiểu rõ chức năng/mục đích đằng sau thông số keepAliveTime được truyền trong hàm tạo. Hy vọng ai đó có thể giải thích cho tôi với một số ví dụ làm việc tốt.

Trích từ Java doc:

public ThreadPoolExecutor(int corePoolSize, 
          int maximumPoolSize, 
          long keepAliveTime, 
          TimeUnit unit, 
          BlockingQueue<Runnable> workQueue) 

keepAliveTime - khi số lượng các chủ đề lớn hơn cốt lõi, đây là thời gian tối đa mà chủ đề nhàn rỗi dư thừa sẽ chờ đợi cho các nhiệm vụ mới trước khi chấm dứt.

Answer 1

Giả sử bạn có kích thước lõi là 5 và kích thước tối đa là 15. Vì lý do nào đó, hồ bơi của bạn bận và sử dụng tất cả 15 chuỗi có sẵn. Cuối cùng bạn đã hết công việc để làm - vì vậy một số chủ đề của bạn trở nên nhàn rỗi khi họ hoàn thành nhiệm vụ cuối cùng của họ. Vì vậy, 10 trong số những chủ đề được phép chết.

Tuy nhiên, để tránh chúng bị tiêu diệt quá nhanh, bạn có thể chỉ định thời gian lưu giữ. Vì vậy, nếu bạn đã chỉ định 1 làm giá trị keepAliveTime và TimeUnit.MINUTE làm giá trị unit, mỗi chuỗi sẽ đợi một phút sau khi hoàn tất việc thực hiện tác vụ để xem có cần phải làm thêm không. Nếu nó vẫn chưa được làm thêm nữa, nó sẽ tự hoàn thành, cho đến khi chỉ có 5 chủ đề trong hồ bơi - "cốt lõi" của hồ bơi.

Answer 2

Dưới đây là một số mô tả nhiều hơn từ Javadoc:

<dt>Keep-alive times</dt> 
* 
* <dd>If the pool currently has more than corePoolSize threads, 
* excess threads will be terminated if they have been idle for more 
* than the keepAliveTime (see {@link 
* ThreadPoolExecutor#getKeepAliveTime}). This provides a means of 
* reducing resource consumption when the pool is not being actively 
* used. If the pool becomes more active later, new threads will be 
* constructed. This parameter can also be changed dynamically 
* using method {@link ThreadPoolExecutor#setKeepAliveTime}. Using 
* a value of <tt>Long.MAX_VALUE</tt> {@link TimeUnit#NANOSECONDS} 
* effectively disables idle threads from ever terminating prior 
* to shut down. 
* </dd> 
* 

Về cơ bản này chỉ cho phép bạn kiểm soát số lượng các đề còn lại trong hồ bơi nhàn rỗi. Nếu bạn thực hiện điều này quá nhỏ (đối với những gì bạn đang làm), bạn sẽ tạo quá nhiều luồng. Nếu bạn làm cho nó quá lớn, bạn sẽ tiêu thụ bộ nhớ/chủ đề mà bạn không cần.

Answer 3

Dưới đây là ví dụ về mã, trong đó chứng tỏ công việc của KeepAliveTime How does maximumPoolSize of ThreadPoolExecutor works?