0

このコードが機能しない理由を理解できません。私がやろうとしているのは、ファイバーを使用して同期コードの動作をエミュレートすることです。

require 'fiber'
require 'eventmachine'

def async_request(url)
  f = Fiber.current
  Thread.new do
    sleep 0.3
    puts 'Resuming Fiber'
    f.resume('page fetched #{url}')
  end
end


def async_get(url)
  async_request url
  val = Fiber.yield
  return val
end

EM.run do 

  Fiber.new do
    puts 'Fiber Started'
    page = async_get('http://www.whatever.com')
    puts page
  end.resume

end

このコードを実行すると、出力は次のようになります。

$ ruby fiber_poc.rb
  Fiber Started
  Resuming Fiber

ファイバが再開されることはありません。どうすればそれができるか説明していただけますか？

みんなありがとう

4

1 に答える 1

1 
require 'fiber'
require 'eventmachine'

def async_request(url)
  f = Fiber.current
  EM.add_timer(0.3) do
    puts 'Resuming Fiber'
    f.resume("page fetched #{url}")
  end
end

def async_get(url)
  async_request url
  Fiber.yield
end

EM.run do 
  Fiber.new do
    puts 'Fiber Started'
    page = async_get('http://www.whatever.com')
    puts page
    EM.stop
  end.resume
end

あなたが得る

#=> Fiber Started
#=> Resuming Fiber
#=> page fetched http://www.whatever.com
于 2013-08-22T14:12:28.997 に答える