# File lib/core/work_queue.rb, line 79 def close() @lock.synchronize { @closed = StoppedError.new } end