lib/zk/threaded_callback.rb in zk-1.5.2 vs lib/zk/threaded_callback.rb in zk-1.5.3
- old
+ new
@@ -114,11 +114,11 @@
ensure
@mutex.unlock rescue nil
end
end
- protected
+ private
# intentionally *not* synchronized
def spawn_dispatch_thread
@thread = Thread.new(&method(:dispatch_thread_body))
end
@@ -131,10 +131,10 @@
@mutex.lock
begin
@cond.wait(@mutex) while @array.empty? and @state == :running
if @state != :running
- logger.warn { "ThreadedCallback, state is #{@state.inspect}, returning" }
+ logger.debug { "ThreadedCallback, state is #{@state.inspect}, returning" }
return
end
args = @array.shift
ensure