जावाटेबल ऐप सर्वर में CompletableFuture/समानांतर स्ट्रीम

Question

नए जावा 8 को देखते हुए हमें असीमित कार्यों के लिए वास्तव में अच्छी सुविधाएं मिल रही हैं, उदा। CompletableFuture और .paralellStream()। यदि आप इसे जावा एसई में चलाते हैं, क्योंकि मैंने इसे समझा है तो आप फोर्कजोइनपूल का उपयोग करेंगे, लेकिन अगर मैं निम्नलिखित उदाहरणों को चलाता हूं तो क्या होता है। वाइल्डफ्लाई या टॉमकैटई?

//Here I start a comp.Future without giving an Executor 
test = CompletableFuture.supplyAsync(() -> timeConsumingMethod()); 
//Here I start a parallel stream 
mList.paralell().filter(...).collect(Collectors.toList()) 

क्या होता है और जहां मैं से अगर

1. उदाहरण एक @Stateful सेम
2. उदाहरण एक @Stateless सेम में भाग रहे हैं में भाग रहे हैं मेरी संसाधन उधार होगा
3. उदाहरण एक सीडीआई बीन

Answer 1

आपको जावा ईई में फोर्कजोइनपूल का उपयोग नहीं करना चाहिए। केवल ऐप सर्वर समानांतरता के लिए संरचनाएं प्रदान करता है (जैसे कि जावा ईई 7 में ManagedExecutorService), क्योंकि threads have to be managed by the container।

उत्सुकता से, this answer में उल्लिखित मेलिंग सूची में एक संदेश है जो दावा करता है कि फोर्कजोइनपूल ईई कंटेनर में सिंगल-थ्रेडेड में गहराई से गिरावट करेगा। मैंने इसका परीक्षण ग्लासफ़िश 4.1 के साथ किया है और सामान्य धागे बनाए जाते हैं।

@Singleton 
public class SomeSingleton { 
    public void fireStream() { 
     IntStream.range(0, 32) 
      .parallel() 
      .mapToObj(i -> String.format("Task %d on thread %s", 
       i, Thread.currentThread().getName())) 
      .forEach(System.out::println); 
    } 
} 

मैं निम्नलिखित उत्पादन प्राप्त:

Info: Task 20 on thread http-listener-1(4) 
Info: Task 10 on thread ForkJoinPool.commonPool-worker-3 
Info: Task 21 on thread http-listener-1(4) 
Info: Task 11 on thread ForkJoinPool.commonPool-worker-3 
Info: Task 22 on thread http-listener-1(4) 
Info: Task 8 on thread ForkJoinPool.commonPool-worker-3 
Info: Task 23 on thread http-listener-1(4) 
Info: Task 9 on thread ForkJoinPool.commonPool-worker-3 
Info: Task 18 on thread http-listener-1(4) 
Info: Task 14 on thread ForkJoinPool.commonPool-worker-3 
Info: Task 19 on thread http-listener-1(4) 
Info: Task 15 on thread ForkJoinPool.commonPool-worker-3 
Info: Task 16 on thread http-listener-1(4) 
Info: Task 17 on thread http-listener-1(4) 
Info: Task 4 on thread http-listener-1(4) 
Info: Task 5 on thread http-listener-1(4) 
Info: Task 6 on thread http-listener-1(4) 
Info: Task 7 on thread http-listener-1(4) 
Info: Task 2 on thread http-listener-1(4) 
Info: Task 3 on thread http-listener-1(4) 
Info: Task 0 on thread http-listener-1(4) 
Info: Task 1 on thread http-listener-1(4) 
Info: Task 26 on thread http-listener-1(4) 
Info: Task 27 on thread http-listener-1(4) 
Info: Task 24 on thread http-listener-1(4) 
Info: Task 25 on thread http-listener-1(4) 
Info: Task 12 on thread http-listener-1(4) 
Info: Task 13 on thread http-listener-1(4) 
Info: Task 30 on thread http-listener-1(4) 
Info: Task 31 on thread http-listener-1(4) 
Info: Task 28 on thread ForkJoinPool.commonPool-worker-0 
Info: Task 29 on thread ForkJoinPool.commonPool-worker-0 

शायद गिरावट जावा ईई 8, जब अधिकांश व्यक्ति विनिर्देशों एसई 8 सुविधाओं का लाभ उठाने जाएगा पर ही उपलब्ध होगा इस कोड चल रहा है।

---

संपादित

मैं glassfish 4.1.1 स्रोत कोड देख लिया है, और वहाँ ForkJoinPool, ForkJoinWorkerThreadFactory या ForkJoinWorkerThread का एक बार उपयोग नहीं है। तो ऐप सर्वर समानांतर संसाधन प्रबंधित करता है उन संरचनाओं में से किसी एक पर आधारित नहीं है। दुर्भाग्य से, वास्तव में कोई गिरावट तंत्र उपलब्ध नहीं है।