lib/cukeforker/worker_queue.rb in cukeforker-0.1.9 vs lib/cukeforker/worker_queue.rb in cukeforker-0.2.0

@@ -3,10 +3,14 @@
     include Observable
 
     def initialize(max)
       @max = max
 
+      if @max < 0
+        raise ArgumentError, "max workers cannot be negative, got #{@max.inspect}"
+      end
+
       @pending = []
       @running = []
       @finished = []
     end
 
@@ -57,10 +61,10 @@
     def size
       @running.size
     end
 
     def full?
-      size == @max
+      @max != 0 && size == @max
     end
 
     def empty?
       @running.empty?
     end