इकाई परीक्षण कैसे करें कि निष्पादक सेवा कार्य के लिए नए धागे को जन्म देती है?

Question

एक यूनिट परीक्षण कैसे करता है कि निष्पादक सेवा का उपयोग करते समय एक रननेबल कार्य के लिए एक नया धागा उत्पन्न हुआ था?

असल में, मेरे पास मेरे आवेदन के लिए एक स्थिर थ्रेड पूल है।

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

मैं इस थ्रेड पूल, बल्कि एक बाहर मजाक या एक नया थ्रेड पूल इंजेक्शन लगाने से, मेरे इकाई परीक्षण के लिए उपयोग करने के लिए के बाद से विभिन्न धागा पूल नाटकीय रूप से अपने आवेदन के व्यवहार में परिवर्तन कर सकते हैं करना चाहते हैं (फिक्स्ड बनाम कैश बनाम अनुसूचित, आदि); मैं यह सुनिश्चित करना चाहता हूं कि मैं अपने रन-टाइम थ्रेड पूल के साथ एप्लिकेशन के व्यवहार का परीक्षण करूं।

कैश्ड थ्रेड पूल मेरे लिए सबसे अच्छा काम करता प्रतीत होता है। समस्या यह है कि चूंकि यह स्थैतिक है और धागे 60 सेकंड के लिए कैश किए जाते हैं, केवल पहले परीक्षण पूल में एक नया धागा पैदा करेगा, जबकि बाद के परीक्षण उस थ्रेड का पुन: उपयोग करेंगे।

यूनिट परीक्षण कोड: यह कैसे काम कर पाने के लिए, या किसी अन्य दृष्टिकोण पूरी तरह से सराहना की जाएगी पर

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

सलाह।

Answer 1

नकली ThreadFactory:

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

1. के रूप में हमेशा की तरह
2. परीक्षण के अंतर्गत वर्ग में ExecutorService सम्मिलित करें लेकिन कैश की गई ThreadPool बनाने के लिए एक कस्टम ThreadFactory का उपयोग करें: ThreadFactory जब भी बुलाया जाएगा एक नया धागा बुलाया जाना है। फिर आप इन इंस्टेंटेशन को अपनी पसंद के अनुसार ढूंढ सकते हैं, उदाहरण के लिए श्रोता या काउंटर के साथ।