Use ObjectSpace instead of class variables and weakrefs. It's just too

easy to lead to a memory leak.

lib/girl_friday.rb

@@ -1,5 +1,4 @@
 require 'thread'
-require 'weakref'
 begin
   # Rubinius
   require 'actor'
@@ -13,16 +12,16 @@
 require 'girl_friday/work_queue'
 require 'girl_friday/error_handler'
 require 'girl_friday/persistence'
+require 'girl_friday/batch'
 
 module GirlFriday
 
-  @@queues = []
   def self.queues
-    @@queues
+    ObjectSpace.each_object(GirlFriday::WorkQueue).to_a
   end
 
   def self.status
-    queues.delete_if { |q| !q.weakref_alive? }.inject({}) { |memo, queue| queue.weakref_alive? ? memo.merge(queue.status) : memo }
+    queues.inject({}) { |memo, queue| memo.merge(queue.status) }
   end
 
   ##
@@ -36,14 +35,14 @@ def self.status
   #
   # WeakRefs make this method full of race conditions with GC. :-(
   def self.shutdown!(timeout=30)
-    queues.delete_if { |q| !q.weakref_alive? }
-    count = queues.size
+    qs = queues
+    count = qs.size
 
     if count > 0
       m = Mutex.new
       var = ConditionVariable.new
 
-      queues.each do |q|
+      qs.each do |q|
         q.shutdown do |queue|
           m.synchronize do
             count -= 1

lib/girl_friday/work_queue.rb

@@ -7,6 +7,7 @@ class WorkQueue
 
     attr_reader :name
     def initialize(name, options={}, &block)
+      raise ArgumentError, "#{self.class.name} requires a block" unless block_given?
       @name = name.to_s
       @size = options[:size] || 5
       @processor = block
@@ -18,7 +19,6 @@ def initialize(name, options={}, &block)
       @total_processed = @total_errors = @total_queued = 0
       @persister = (options[:store] || Store::InMemory).new(name, (options[:store_config] || []))
       start
-      GirlFriday.queues << WeakRef.new(self)
     end
 
     if defined?(Rails) && Rails.env.development?