Làm thế nào để kiểm tra đơn vị rằng ExecutorService sinh ra chuỗi mới cho công việc?

Question

Làm thế nào để một đơn vị kiểm tra rằng một luồng mới được sinh ra cho một nhiệm vụ Runnable khi sử dụng một ExecutorService?

Về cơ bản, tôi có một nhóm luồng tĩnh cho ứng dụng của mình.

public static final ExecutorService executorService = Executors.newCachedThreadPool(); 

Tôi muốn sử dụng nhóm chủ đề này cho các bài kiểm tra đơn vị của mình, thay vì chế nhạo hoặc thêm một nhóm chủ đề mới. được lưu trong bộ nhớ cache so với lịch biểu, v.v.); Tôi muốn đảm bảo rằng tôi kiểm tra hành vi của ứng dụng với nhóm luồng thời gian chạy của nó.

Hồ sơ chuỗi được lưu trong bộ nhớ cache có vẻ phù hợp nhất với tôi. Vấn đề là vì nó tĩnh và các luồng được lưu trữ trong 60 giây, chỉ thử nghiệm đầu tiên mới thực sự tạo ra một luồng mới trong nhóm, trong khi các phép kiểm tra tiếp theo sử dụng lại luồng đó. mã kiểm tra

Đơn vị:

public void testDoCallExecutesTaskInAnotherThread() {  
    final Client client = this.createClient(); 
    final ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) client.getExecutorService(); // gets the static thread pool 
    final int initPoolSize = threadPoolExecutor.getPoolSize(); 
    final Response response = client.doCall(); 
    Assert.assertEquals(initPoolSize + 1, threadPoolExecutor.getPoolSize()); 
} 

Tư vấn về làm thế nào để làm việc này, hoặc cách tiếp cận khác hoàn toàn sẽ được đánh giá.

Answer 1

Mock các ThreadFactory:

ThreadFactory mock = new CustomObservableThreadFactory(); 
    ExecutorService executorService = Executors.newCachedThreadPool(mock); 

1. Chích ExecutorService vào lớp dưới kiểm tra như thường lệ
2. Nhưng sử dụng một tùy chỉnh ThreadFactory để tạo ThreadPool cache: Các ThreadFactory sẽ được gọi bất cứ khi nào một Thread mới sẽ được gọi. Sau đó, bạn có thể theo dõi các cảnh báo này theo ý muốn, ví dụ: với trình nghe hoặc bộ đếm.