Ruby thread内sleepコール実行中 threadそのものを停止させたい

Question

yama@roswell:$ uname -a
CYGWIN_NT-6.3 JPC20165182 2.6.0(0.304/5/3) 2016-08-31 14:32 x86_64 Cygwin
yama@roswell:$ ruby --version ruby 2.2.5p319 (2016-04-26 revision 54774) [x86_64-cygwin]
の環境で、

2つのthread
input_thread,exec_thread
を用いて、

input_threadにて、標準入力より p がタイプされると、
exec_thread を thread.sleep で、sleep状態にしています。
(下記コードの (*1) の部分)

exec_thread 内で、sleepコールで、既にsleep状態になっている場合
(下記コードの(*2)の部分)
sleepコールで、指定した時間が来れば、run状態になりますが...

exec_threadそのものの動きを止めたい、すなわちsleepコールの動きのそのもの
を止めたい場合は、
どうすればよいのかご教示いただけますでしょうか？

簡単に説明すると、
input_thread で、標準入力より p がタイプされると、exec_thread を停止。
また、p がタイプされると、exec_thread 再開。
但し、exec_thread 再開後は、停止した際から、sleep設定時間の残り時間を
exec_threadは実行というような感じにしたいのです。

exec_thread = Thread.new do
   loop do
       puts "in exec_thread"   
       n = 30 # sleep specified secs  
       puts "in exec_thread sleep start #{n}s"  
       sleep(n) # (*2)   
       puts "in exec_thread sleep end"  
    end  
end  
 
input_thread = Thread.new do
 loop do  
   ret = STDIN.gets  
 
   case ret  
   when /^ *q *$/  
     puts "get q"  
     exit  
   when /^ *p *$/     
     puts "get p" # (*1)  
     exec_thread.stop
   end  
 end  
end 

exec_thread.join  
input_thread.join  

Answer 1

otn さんのアドバイスを元に、下記のような自己解決に至りました。
もっとこうした方が良い等のアドバイス有れば、ご教示ください。

q = Queue.new

exec_thread = Thread.new do
  puts "in exec_thread"

  ets = :run # ets: exec thread status

  loop do

    n = 30 # sleep specified secs
    puts "in exec_thread sleep start #{n}s"

    loop do
      begin
        etc = q.pop(non_block = true) # etc : exec thread control

        case ets
        when :run
          if etc == :stop
            puts "in exec_thread goes to sleep stop mode"
            ets = :stop
          end
        when :stop
          if etc == :run
            puts "in exec_thread goes to sleep run mode"
            ets = :run
          end
        end
      rescue => e
        case ets
        when :run
          puts "sleep count down #{n}"
          sleep(1)
          n -= 1
          break if n < 0
        when :stop
        else # do nothing
        end
      end
    end
  end
end

input_thread = Thread.new do
  ets = :run # ets: execute thread status

  loop do
    ret = STDIN.gets

    case ret
    when /^ *q *$/
      puts "get q"
      exit
    when /^ *p *$/    
      puts "get p"
      if ets == :run
        ets = :stop
        q.push(:stop)
      else
        ets = :run
        q.push(:run)
      end
    end
  end
end

exec_thread.join
input_thread.join

Answer 2

1秒(あるいはそれ以下)ずつsleepするようにして、自分で残り待ち時間をカウントダウンするしかないと思います。

Comments

[roswell]

otn さん、回答ありがとうございます。

> 自分で残り待ち時間をカウントダウンするしかない

の "自分で" というのは、"exec_thread で" ということでしょうか？

[otn]

はい。sleepしたいthreadでという意味です。

[roswell]

otn さん

> 自分で残り時間をカウントする...

下記の様にコード変更してみましたが...、他 thread から stop を call しても、
結局 sleep している箇所自体は動く訳で、望んだ動作にはならないようなのですが
何か勘違いしていますでしょうか？

exec_thread をこのように改変すれば良い等の具体例を、もしよろしければご教示いただけないでしょうか？

■最初にいただいたアドバイスの様に自分でカウントダウンするようにした？ コード
exec_thread = Thread.new do
loop do
puts "in exec_thread"

n = 30 # sleep specified secs
puts "in exec_thread sleep start #{n}s"

while n > 0 do
sleep(1)
n -= 1
end

puts "in exec_thread sleep end"
end
end