Почему мой код клиента eventmachine не работает асинхронно?

def index 
    p "INDEX, #{Fiber.current.object_id}" # <- #1 
    EventMachine.run { 
    http = EventMachine::HttpRequest.new('http://google.com/').get :query => {'keyname' => 'value'} 

    http.errback { p "Uh oh, #{Fiber.current.object_id}"; EM.stop } # <- #2 
    http.callback { 
     p "#{http.response_header.status}, #{Fiber.current.object_id}" # <- #3 
     p "#{http.response_header}" 
     p "#{http.response}" 

     EventMachine.stop 
    } 
    } 

    render text: 'test1' 
end

В этом коде я ожидал получать различный Fiber идентификатор в #1, #2, #3 линии. Но идентификатор всех объектов волокна был таким же. Я пробовал Thread.current.object_id, но это был тот же результат.
Что я не понимаю? Этот код даже выполняется асинхронно?Почему мой код клиента eventmachine не работает асинхронно?

P.S Я использую ruby 2.0 и код работает с rails4

источник

2013-07-22 Benjamin

Вы должны использовать em-synchrony для просмотра своих волокон :) – fl00r

http://ruby-doc.org/core-2.0/Fiber.html

Fibers are primitives for implementing light weight cooperative concurrency in Ruby. Basically they are a means of creating code blocks that can be paused and resumed, much like threads. The main difference is that they are never preempted and that the scheduling must be done by the programmer and not the VM.

Где в вашем коде вы планирования волокна, например, вызывая Fiber.yield или my_fiber.resume?

current() → fiber
Returns the current fiber. You need to require 'fiber' before using this method. If you are not running in the context of a fiber this method will return the root fiber.

В каком коде вы создали дополнительные волокна, например. Fiber.new do ...?

Is that code even executes asynchronously?

require 'em-http-request' 
require 'fiber' 

puts Fiber.current.object_id 

def index 
    p "INDEX, #{Fiber.current.object_id}" # <- #1 
    EventMachine.run { 
    http = EventMachine::HttpRequest.new('http://google.com/').get :query => {'keyname' => 'value'} 

    http.errback { p "#{Uh oh}, #{Fiber.current.object_id}"; EM.stop } # <- #2 
    http.callback { 
     p "#{http.response_header.status}, #{Fiber.current.object_id}" # <- #3 
     p "#{http.response_header}" 
     p "#{http.response}" 

     EventMachine.stop 
    } 
    } 

    #render text: 'test1' 
end 

index() 

--output:-- 
2157346420 
"INDEX, 2157346420" 
"301, 2157346420" 
"{\"LOCATION\"=>\"http://www.google.com/?keyname=value\", \"CONTENT_TYPE\"=>\"text/html; charset=UTF-8\", \"DATE\"=>\"Mon, 22 Jul 2013 08:44:35 GMT\", \"EXPIRES\"=>\"Wed, 21 Aug 2013 08:44:35 GMT\", \"CACHE_CONTROL\"=>\"public, max-age=2592000\", \"SERVER\"=>\"gws\", \"CONTENT_LENGTH\"=>\"233\", \"X_XSS_PROTECTION\"=>\"1; mode=block\", \"X_FRAME_OPTIONS\"=>\"SAMEORIGIN\", \"CONNECTION\"=>\"close\"}" 
"<HTML><HEAD><meta http-equiv=\"content-type\" content=\"text/html;charset=utf-8\">\n<TITLE>301 Moved</TITLE></HEAD><BODY>\n<H1>301 Moved</H1>\nThe document has moved\n<A HREF=\"http://www.google.com/?keyname=value\">here</A>.\r\n</BODY></HTML>\r\n"

Неа.

И это ошибка:

http.errback { p "#{Uh oh}" ...

источник

2013-07-22 08:10:44 7stud

+1, я думаю, что код работает. Fiber находится в EventMachine и em-http-request library. И ваш ответ «Нет» еще не ясен, чтобы понять, как это работает. 'errback' исправлено. – Benjamin

'Я думаю, что код работает. Fiber находится в EventMachine' Нет. Посмотрите на код внимательно, затем посмотрите на object_id на выходе. – 7stud

В качестве search of the repository шоу, em-http не использует волокна по умолчанию. Ссылка, однако, показывает пример того, как вы можете использовать волокна, если вы так склонны.

источник

2013-07-26 22:36:14 Sim

Почему мой код клиента eventmachine не работает асинхронно?

ответ

Смежные вопросы