Почему одновременный выход из рубина немедленно - PullRequest
0 голосов
/ 15 октября 2019

Я пытаюсь использовать concurrent-ruby для выполнения некоторых параллельных задач, я слежу за документом и использую Concurrent::Async:

require 'concurrent'

class Echo
  include Concurrent::Async

  def echo(msg)
    p msg
  end
end

horn = Echo.new
horn.async.echo('one')

и запускаю его в терминале, но обрабатываюничего не печатать и немедленно выйти

1 Ответ

1 голос
/ 16 октября 2019
require 'concurrent'

class Echo
  include Concurrent::Async

  def echo(msg)
    p msg
  end
end

horn = Echo.new

# t is an instance of Concurrent::IVar which includes Concurrent::Concern::Obligation
t = horn.async.echo('one')

# wait until obligation is complete or the timeout has been reached
t.wait! 

код соуса

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...