Запуск и остановка потоков Ruby

Question

Запуск и остановка потоков Ruby

Как я Запустил бы и остановил бы отдельный поток из другого потока?

loop_a_stopped = true
loop_a = Thread.new do
    loop do
        Thread.stop if loop_a_stopped

        # Do stuff

        sleep 3
    end
end

loop_b = Thread.new do
    loop do
        response = ask("> ")
        case response.strip.downcase
            when "start"
                loop_a_stopped = false
                loop_a.run
            when "stop"
                loop_a_stopped = true
            when "exit"
                break
        end
    end
end

loop_a.join
loop_b.join

6

ruby multithreading

задан RyanScottLewis 22 December 2009 в 20:34

1 ответ

Другие вопросы по тегам:

ruby multithreading

Похожие вопросы:

score 8 · Answer 1

Вот исправленная версия вашего примера:

STDOUT.sync = true

loop_a_stopped = true

loop_a = Thread.new do
    loop do
        Thread.stop if loop_a_stopped

        # Do stuff

        sleep(1)
    end
end

loop_b = Thread.new do
    loop do
        print "> "
        response = gets

        case response.strip.downcase
        when "start"
          loop_a_stopped = false
          loop_a.wakeup
        when "stop"
          loop_a_stopped = true
        when "exit"
          # Terminate thread A regardless of state
          loop_a.terminate!
          # Terminate this thread
          Thread.exit
        end
    end
end

loop_b.join
loop_a.join

Управление потоками может быть немного сложным. Остановка потока не завершает его, а просто удаляет его из планировщика, поэтому вам действительно нужно убить его с помощью Thread # terminate! прежде, чем это действительно будет закончено.