Come testare l'unità che ExecutorService genera un nuovo thread per l'attività?

Question

In che modo un'unità verifica se è stato generato un nuovo thread per un'attività Runnable quando utilizza un ExecutorService?

Fondamentalmente, ho un pool di thread statici per la mia applicazione.

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

vorrei utilizzare questo pool di thread per i miei test di unità, piuttosto che beffardo uno fuori o iniettando un nuovo pool di thread, dal momento che diversi pool di thread possono alterare notevolmente il comportamento della mia applicazione (vs fisso memorizzato nella cache o programmato, ecc.); Voglio assicurarmi di testare il comportamento dell'applicazione con il suo pool di thread in fase di esecuzione.

Il pool di thread memorizzato nella cache sembra funzionare meglio per me. Il problema è che poiché è statico e i thread sono memorizzati nella cache per 60 secondi, solo il primo test genererà un nuovo thread nel pool, mentre i test successivi riutilizzeranno quel thread.

Unità codice di prova:

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()); 
} 

I consigli per ottenere questo funzionamento, o un altro approccio del tutto sarebbe apprezzato.

Answer 1

Mock il ThreadFactory:

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

1. Iniettare l'ExecutorService nella classe in prova, come al solito
2. ma utilizzare un ThreadFactory personalizzato per la creazione del ThreadPool cache: Il ThreadFactory sarà chiamato ogni volta un nuovo thread deve essere chiamato. È quindi possibile tracciare queste istanze come desiderato, ad es. Con un listener o contatore.