रुबी में कार्य/भविष्य

Question

एक पैटर्न के बेवकूफ रूबी एनालॉग क्या है जो संभावित रूप से स्थगित असीमित गणना का प्रतिनिधित्व करता है जिसके पूरा होने की सदस्यता लेने की संभावना है? यानी .NET System.Threading.Task, या पायथन 3.x concurrent.futures.future की लाइनों के साथ कुछ।

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

Answer 1

फाइबर?

रूबी रूबी में हल्के वजन सहकारी समेकन को लागू करने के लिए प्राथमिक हैं। असल में वे कोड ब्लॉक बनाने का साधन हैं जिन्हें थ्रेड की तरह, रोका जा सकता है और फिर से शुरू किया जा सकता है। मुख्य अंतर यह है कि उन्हें कभी भी छूट नहीं दी जाती है और शेड्यूलिंग प्रोग्रामर द्वारा की जानी चाहिए, न कि वीएम। link

Answer 2

मुझे वेनिला रूबी के बारे में निश्चित नहीं है, लेकिन EventMachine deferrables है।

इसके अलावा, this article देखें।

EM.run { 
    detector = LanguageDetector.new("Sgwn i os yw google yn deall Cymraeg?") 
    detector.callback { |lang| puts "The language was #{lang}" } 
    detector.errback { |error| puts "Error: #{error}" } 
} 

Answer 3

आप पर एक कॉलबैक होने से resque
की तरह एक नौकरी कतार उपयोग कर सकते हैं एक बच्चे की प्रक्रिया

rd, wr = IO.pipe 

p1 = fork do 
    rd.close 
    # sleep is for demonstration purpose only 
    sleep 10 
    # the forked child process also has a copy of the open file 
    # handles, so we close the handles in both the parent and child 
    # process 
    wr.write "1" 
    wr.close 
end 

wr.close 

puts "Process detaching | #{Time.now}" 
Process.detach(p1) 
puts "Woot! did not block | #{Time.now}" 

1.upto(10) do 
    begin 
    result = rd.read_nonblock(1) 
    rescue EOFError 
    break 
    rescue Exception 
    # noop 
    end 

    puts "result: #{result.inspect}" 
    system("ps -ho pid,state -p #{p1}") 
    sleep 2 
end 

rd.close 

__END__ 

ruby 1.9.2p180 (2011-02-18 revision 30909) [x86_64-darwin10.6.0] 
Process detaching | 2012-02-28 17:05:49 +0530 
Woot! did not block | 2012-02-28 17:05:49 +0530 
result: nil 
    PID STAT 
5231 S+ 
result: nil 
    PID STAT 
5231 S+ 
result: nil 
    PID STAT 
5231 S+ 
result: nil 
    PID STAT 
5231 S+ 
result: nil 
    PID STAT 
5231 S+ 
result: "1" 
    PID STAT 

forking द्वारा शुद्ध माणिक

1. के कुछ त्वरित उदाहरण कोडित है एक धागा

   require 'thread' 
   
   Thread.abort_on_exception = true 
   
   module Deferrable 
       def defer(&block) 
       # returns a thread 
       Thread.new do 
        # sleep is for demonstration purpose only 
        sleep 10 
   
        val = block.call 
        # this is one way to do it. but it pollutes the thread local hash 
        # and you will have to poll the thread local value 
        # can get this value by asking the thread instance 
        Thread.current[:human_year] = val 
        # notice that the block itself updates its state after completion 
       end 
       end 
   end 
   
   class Dog 
       include Deferrable 
       attr_accessor :age, :human_age 
       attr_accessor :runner 
   
       def initialize(age=nil) 
       @age = age 
       end 
   
       def calculate_human_age_as_deferred! 
       self.runner = defer do 
        # can do stuff with the values here 
        human_age = dog_age_to_human_age 
        # and finally publish the final value 
        after_defer { self.human_age = human_age } 
        # return value of the block. used in setting the thread local 
        human_age 
       end 
       end 
   
       protected 
       def dog_age_to_human_age 
       (self.age/7.0).round(2) 
       end 
   
       def after_defer(&block) 
       block.call 
       end 
   end 
   
   dog = Dog.new(8) 
   dog.calculate_human_age_as_deferred! 
   
   1.upto(10) do 
       sleep 2 
       puts "status: #{dog.runner.status} | human_age: #{dog.human_age.inspect}" 
       break unless dog.runner.status 
   end 
   
   puts "== using thread local" 
   
   dog = Dog.new(8) 
   dog.calculate_human_age_as_deferred! 
   
   1.upto(10) do 
       sleep 2 
       puts "status: #{dog.runner.status} | human_age: #{dog.runner[:human_year].inspect}" 
       break unless dog.runner.status 
   end 
   
   __END__ 
   
   ruby 1.9.2p180 (2011-02-18 revision 30909) [x86_64-darwin10.6.0] 
   status: sleep | human_age: nil 
   status: sleep | human_age: nil 
   status: sleep | human_age: nil 
   status: sleep | human_age: nil 
   status: false | human_age: 1.14 
   == using thread local 
   status: sleep | human_age: nil 
   status: sleep | human_age: nil 
   status: sleep | human_age: nil 
   status: sleep | human_age: nil 
   status: false | human_age: 1.14 
   

---

धागे एक बच्चे प्रक्रिया forking लेकिन forking मजबूत है की तुलना में कम स्मृति खपत करते हैं। धागे में एक अनचाहे त्रुटि पूरे सिस्टम को नीचे ला सकती है। जबकि एक बच्चे की प्रक्रिया में एक बिना क्रिया त्रुटि, इकलौती संतान प्रक्रिया

अन्य लोगों को फाइबर और eventmachine ने बताया है नीचे लाना होगा (ईएम का उपयोग कर :: Deferrable और EM.defer) एक और विकल्प

रेशे और धागे की जरूरत है सावधानीपूर्वक कोडिंग। कोड सूक्ष्म तरीकों से गलत हो सकता है। इसलिए codebase अच्छी तरह व्यवहार किया जाना

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

Answer 4

शायद मुझे कुछ याद आ रही है, लेकिन अगर स्थिति गहराई से आपकी प्रतिक्रिया में वर्णित है, तो क्यों सी एपीआई को रूबी के रूप में लपेटें विस्तार और एक रूबी विधि प्रदान करें जो आपके आवश्यक कॉलबैक से संबंधित ब्लॉक स्वीकार करता है? यह भी बहुत मूर्खतापूर्ण रूबी होगा।

रूबी 1.9: http://media.pragprog.com/titles/ruby3/ext_ruby.pdf के लिए अपडेट की गई "पिकैक्स" पुस्तक से रू के साथ रूबी को विस्तारित करने के साथ एक नमूना अध्याय है।

अद्यतन: यहाँ कुछ रूबी में रूबी अपवादों के साथ और यह सी इंटरफ़ेस है में काम कर लिंक्स हैं।

• http://rubylearning.com/satishtalim/ruby_exceptions.html
• http://clalance.blogspot.com/2011/01/writing-ruby-extensions-in-c-part-5.html
• http://clalance.blogspot.com/2011/01/writing-ruby-extensions-in-c-part-6.html

Answer 5

lazy.rb "वायदा" प्रदान करता है, लेकिन वे बिल्कुल वैसा ही आप का वर्णन के रूप में होने के लिए नहीं है (या मैं उम्मीद होती है):

इसके अतिरिक्त, लाइब्रेरी वायदा प्रदान करती है, जहां एक गणना तुरंत चलती है एक पृष्ठभूमि धागे में।

तो, आप बाद में उनकी गणना नहीं कर सकते हैं, या अन्य तरीकों से उनमें से मूल्य (नेटवर्क से शायद) सम्मिलित नहीं कर सकते हैं।

Answer 6

मैंने पाया यह अत्यंत उपयोगी होने के लिए:

https://github.com/wireframe/backgrounded

यह एक मणि कि बस एक पृष्ठभूमि कार्य पर तरीकों को आगे बढ़ाने के लिए अनुमति देता है।

Answer 7

thread मणि ब्याज का हो सकता है। आप एक थ्रेड-पूल बना सकते हैं जो पृष्ठभूमि में सामान को संसाधित करता है। मणि भविष्य, देरी इत्यादि जैसी कई अन्य सुविधाओं का भी समर्थन करता है। the github repo पर एक नज़र डालें।

यह रूबी संस्करणों की विस्तृत श्रृंखला के साथ काम करता है, न केवल 1.9+, इसलिए मैं इसका उपयोग करता हूं।