multithreading - Python multi threading with queue -

-

यह मेरा कोड है; 

  पंक्ति आयात से आयात थ्रेडिंग पंक्ति शब्द = खुला (" Word.txt ") लॉक = थ्रेडिंग। लॉक () धागे = 10 क्यू = क्व्यू (अधिकतम आकार = 0) def myfunction (q): lock.acquire () प्रिंट q.get () lock.release () q.task_done () के लिए रेंज (धागे) में एक्स: धागा = धागा। धागा (लक्ष्य = myfunction, args = (q,)) m.setDaemon (सही) m.start () शब्दों में शब्द के लिए: q.put (word.strip () ) Q.join () raw_input ()

यह आउटपुट होगा: 

  शब्द 1 शब्द 2 शब्द 3 शब्द 4 शब्द 5 शब्द 6 शब्द 7 शब्द 8 शब्द 7 शब्द 10 शब्द 10   
 तब यह बंद हो जाएगा फ़ाइल में बहुत अधिक शब्द हैं, मैं इसे कैसे जारी रख सकता हूं? मेरी समझ से, q.join () को तब तक इंतजार करना चाहिए जब तक क्यूई रिक्त नहीं है और अधिक जोड़ने के लिए। 
 
 मैंने सोचा था कि इसे इस तरह से एक पाश में डालना: 
 
  शब्द के लिए शब्दों में: रेंज (थ्रेड) में एक्स के लिए q.put (word.strip ()): m = थ्रेडिंग। धागा (लक्ष्य = myfunction, args = (q,)) m.setDaemon (True) m.start () < / Code> 
 
 लेकिन कभी-कभी मुझे यह कहते हुए एक त्रुटि मिलती है "नया थ्रेड प्रारंभ नहीं किया जा सकता"।

अपने धागे को एक कतार वस्तु के संसाधित करने के बाद बस खत्म हो जाते हैं।

वर्कर कोड (अर्थात myfunction के शरीर को) को में रखें, जबकि: True लूप ताकि यह क्यूई से अधिक आइटम प्राप्त करने पर रहता है, एक बार q.task_done () को बुलाया गया था।


Comments

Post a Comment

Popular posts from this blog

Folder list php -

-
I want to list folder names in the list. There is a file to show the folder name. There is already a problem, please do a test. Another code would be OK. & lt ;? Php function getFileList ($ folder name, $ fileType = "") {if (substr ($ folderName, strlen ($ folderName) - 1)! = "/") {$ Folder name. = '/'; } Foreach (Globe ($ folderName. '*'. $ FileType) $ filename) {if_dir ($ filename)) {$ type = 'folder'; } And {$ type = 'file'; } Echo str_replace ($ folderName, '', $ filename. ' '); }} // call function getFileList ('folder name'); // List of all files? & Gt; & Lt; Select class = "form" name = "userlevel" size = "1" & gt; & Lt; Option value = "& lt ;? php getFileList ('theme') ;? & gt;" & Gt; فولدر 1 & lt; / Options & gt; & Lt; Option value = "& lt ;? php getFileList ('theme') ;? & gt;" ...
Read more

symfony - FOSUser mail is translated but confirmation_url isn't -

-
I found an easy way to add a location to my Symphony routes, as here: Some of the relevant settings in my project: Config Framework: Translator: {Fallback: "% locale%"} default_lock: Nl Services FOSMailer: @ FOS_UJ. Mailer. Twig_swift Routing fos_user_register: resource: "@ FOSUserBundle / resources / config / routing / registration.xml" Prefix: / {_ locale} / registreren I am trying to get FOSUser to send confirmation mail in the newly created user's browser language. For this, I am saving the place I have received by Javascript in my database. Then, I am setting up my request for that locale and manually send the confirmation mail: $ request-> Setlokel ($ locale); // ($ locale = 'en_US') $ Mailer = $ this- & gt; Get ('fosmailer'); $ Mailer- & gt; SendConfirmationEmailMessage ($ user); In the email template {{'foobar' | Trans}} tags that work perfectly fine. But I am also using {{confi...
Read more

java - org.apache.http.ProtocolException: Target host is not specified -

-
I have written a simple httprequest / response code and I am getting this error below: I used to type in my classpath httpclient, httpcore, common -Codecs and general logging. I am very new to Java and I do not know what's going on here. Please help me. code: import org.apache.http.client.HttpClient; Import org.apache.http.client.methods.HttpGet; Import org.apache.http.HttpResponse; Import org.apache.http.impl.client.HttpClientBuilder; Import org.apache.http.Header; Import org.apache.http.HttpHeaders; Public class UnshorteningUrl {public static zero main (string [] args throws exception {HttpGet request = zero; HTTP Client Client = HTTP ClientBuilder.credit (). Build (); Try {Request = New HTTP Gate ("trib.me/1lBFzSi"); HttpResponse httpResponse = client.execute (request); Header [] header = httpResponse.getHeaders (HttpHeaders.LOCATION); // Preconditions.checkState (headers.length == 1); String new url = header [0] .getValue (); System.out.println ("new url...
Read more