Articles of निष्पादक सेवा

जावा निष्पादक: मैं कार्य को कैसे रोक सकता हूं?

मैंने निष्पादकों का उपयोग करने के लिए एक कार्य सबमिट किया है और मुझे कुछ समय (जैसे 5 मिनट) के बाद रोकना होगा। मैंने ऐसा करने की कोशिश की है: for (Future<?> fut : e.invokeAll(tasks, 300, TimeUnit.SECONDS)) { try { fut.get(); } catch (CancellationException ex) { fut.cancel(true); tasks.clear(); } catch(ExecutionException ex){ ex.printStackTrace(); //FIXME: gestita con […]

सभी धागा पूल अपने काम करने के लिए invokeAll () का उपयोग कैसे करें?

ExecutorService pool=Executors.newFixedThreadPool(7); List<Future<Hotel>> future=new ArrayList<Future<Hotel>>(); List<Callable<Hotel>> callList = new ArrayList<Callable<Hotel>>(); for(int i=0;i<=diff;i++){ String str="2013-"+(liDates.get(i).get(Calendar.MONTH)+1)+"-"+liDates.get(i).get(Calendar.DATE); callList.add(new HotelCheapestFare(str)); } future=pool.invokeAll(callList); for(int i=0;i<=future.size();i++){ System.out.println("name is:"+future.get(i).get().getName()); } अब मैं पूल को invokeAll करना चाहता हूं, लूप तक पहुंचने से पहले सभी काम करना है, लेकिन जब मैं इस प्रोग्राम को लूप के लिए चलाता हूँ, तब उस invokeAll से […]

ThreadPool एक्सक्लोरर ब्लॉक जब कतार पूर्ण है?

मैं एक ThreadPoolExecutor का उपयोग करके बहुत सी कार्य निष्पादित करने की कोशिश कर रहा हूँ नीचे एक काल्पनिक उदाहरण है: def workQueue = new ArrayBlockingQueue<Runnable>(3, false) def threadPoolExecutor = new ThreadPoolExecutor(3, 3, 1L, TimeUnit.HOURS, workQueue) for(int i = 0; i < 100000; i++) threadPoolExecutor.execute(runnable) समस्या यह है कि मैं जल्दी से एक java.util.concurrent.RejectedExecutionException प्राप्त […]

जावा: निष्पादक सेवा कि एक निश्चित कतार आकार के बाद सबमिशन पर ब्लॉक करता है

मैं एक ऐसे समाधान के कोड की कोशिश कर रहा हूं जिसमें एक धागा I / O- गहन कार्यों का उत्पादन करता है जो समानांतर में किया जा सकता है। प्रत्येक कार्य में महत्वपूर्ण स्मृति डेटा हैं इसलिए मैं एक क्षण में लंबित कार्यों की संख्या को सीमित करने के लिए चाहता हूं अगर मैं […]

जावा निष्पादक सेवा: सभी पुनरावर्ती निर्माण कार्यों का इंतजार

मैं कार्य निष्पादित करने के लिए एक ExecutorService का उपयोग करता हूं। यह कार्य फिर से दूसरे कार्यों को बना सकता है जो उसी ExecutorService को सबमिट किए जाते हैं और उन बाल कार्यों को भी ऐसा कर सकते हैं मुझे अब समस्या है, जब तक कि मैं जारी रखने से पहले सभी कार्य (जो […]

कैसे एक निष्पादक सेवा बंद करने के लिए?

जब भी मैं shutdownNow() या shutdown() यह बंद नहीं करता है मैंने कुछ धागे पढ़े हैं जहां यह कहा था कि बंद करने की गारंटी नहीं है – क्या कोई मुझे यह करने का एक अच्छा तरीका प्रदान कर सकता है?

आकार सीमा के साथ एक कैश थ्रेड पूल बनाने के लिए असंभव?

ऐसा लगता है कि किसी थैरे की एक सीमा के साथ कैश थ्रेड पूल बनाने के लिए असंभव प्रतीत होता है जो इसे बना सकता है। यहां बताया गया है कि कैसे स्थिर निष्पादनकर्ताओं। न्यूकैचैडथ्रेडपूल मानक जावा लाइब्रेरी में कार्यान्वित किया गया है: public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new […]

जावा का फोर्क / बनाम एक्जीक्यूटर्स सेवा – जब किसका उपयोग किया जाए?

मैंने अभी इस पोस्ट को पढ़ना समाप्त कर दिया है: जावा -7 थ्रेडपूल एक्सपोजर का जावा -7 फोर्कज्यूनपूल पर क्या फायदे हैं? और महसूस किया कि इसका उत्तर सीधे पर्याप्त नहीं है क्या आप साधारण भाषा और उदाहरणों में व्याख्या कर सकते हैं, जावा 7 के फोर्क-फ़्रेमवर्क और पुराने समाधानों के बीच व्यापार-बंद क्या हैं? […]

कैसे ठीक जावा निष्पादक का उपयोग करने के लिए?

मैंने अपने मल्टी-थ्रेडिंग ऐप्स में जावा निष्पादकों का उपयोग किया है, लेकिन मुझे यह पता नहीं लग सकता है कि निम्नलिखित तरीकों से प्रत्येक का उपयोग करने के लिए सबसे अच्छा कब है: 1। ExecutorService executor=Executors.newFixedThreadPool(50); executor.execute(new A_Runner(… some parameter …)); executor.shutdown(); while (!executor.isTerminated()) { Thread.sleep(100); } 2। int Page_Count=200; ExecutorService executor=Executors.newFixedThreadPool(50); doneSignal=new CountDownLatch(Page_Count); for […]

निष्पादक.न्यूकैचड थ्रेडपूल () बनाम निष्पादक। एनवेफिक्सट्रेडपूल ()

newCachedThreadPool() बनाम newFixedThreadPool() मुझे एक या दूसरे का उपयोग कब करना चाहिए? संसाधन उपयोग के संदर्भ में कौन सा रणनीति बेहतर है?

दिलचस्प पोस्ट
यह जानने के लिए कि किस प्रक्रिया का उपयोग किया गया फ़ाइल है? सिंक के बाहर आदेश; आप अब यह आदेश नहीं चला सकते Prolog – सूची में पुनरावृत्तियों गिनती गेटर और सेटर? शॉर्ट रोट 13 फ़ंक्शन – पायथन Droppable की घटना के बाहर एक jQuery ड्रैग करने योग्य वस्तु वापस अपने मूल कंटेनर पर वापस लौटें Matplotlib का उपयोग करते हुए इन्ट्राडे कैंडेलेस्टिक चार्ट कैसे चर का मूल्य बदलने के लिए तर्क के रूप में पारित? कार्यक्षेत्र पाठ दिशा उच्च गुणवत्ता वाली छवियों के साथ कैनवास निर्यात करने का सर्वोत्तम अभ्यास क्या है? मेटलोपलिब ऑब्जेक्ट-ओरिएंटेड इंटरफ़ेस का उपयोग करके समुद्री कार्बन के साथ प्लॉटिंग क्लोज़र में वैरिएबल कैप्चर की विस्तृत व्याख्या ईएफ: जिसमें खंड के साथ शामिल करें सार्वजनिक कुंजी उत्पन्न करने के लिए आरएसए निजी कुंजी का उपयोग करें? 'जीआईटी मर्ज' और 'गिट रिबेस' के बीच अंतर क्या है?