- style cleanup

- Add MultiQueue#<< alias to #push
This commit is contained in:
Jordan Sissel 2011-02-21 19:12:23 -08:00
parent 85db3348df
commit 08abcbea9d

View file

@ -1,13 +1,19 @@
class MultiQueue
public
def initialize(*queues)
@mutex = Mutex.new
@queues = queues
end
# Push an object to all queues.
public
def push(object)
@queues.each { |q| q.push(object) }
end
alias_method :<<, :push
# Add a new Queue to this queue.
public
def add_queue(queue)
@mutex.synchronize do