class SQS::Job::ThreadPool::AutoTrim
Public Class Methods
new(pool, timeout)
click to toggle source
# File lib/sqs/job/thread_pool.rb, line 141 def initialize(pool, timeout) @pool = pool @timeout = timeout @running = false end
Public Instance Methods
start!()
click to toggle source
# File lib/sqs/job/thread_pool.rb, line 147 def start! @running = true @thread = Thread.new do while @running @pool.trim sleep @timeout end end end
stop()
click to toggle source
# File lib/sqs/job/thread_pool.rb, line 158 def stop @running = false @thread.wakeup end