use a pipe to put the main process to sleep

Conflicts:

	lib/resque/worker.rb

Author: tenderlove

lib/resque/worker.rb

@@ -128,7 +128,9 @@ def work(interval = 5.0, &block)
       loop do
         break if shutdown?
 
-        if not paused? and job = reserve(interval)
+        pause if should_pause?
+
+        if job = reserve(interval)
           log "got: #{job.inspect}"
           job.worker = self
           run_hook :before_fork, job
@@ -273,7 +275,6 @@ def register_signal_handlers
         trap('QUIT') { shutdown   }
         trap('USR1') { kill_child }
         trap('USR2') { pause_processing }
-        trap('CONT') { unpause_processing }
       rescue ArgumentError
         warn "Signals QUIT, USR1, USR2, and/or CONT not supported."
       end
@@ -314,9 +315,22 @@ def kill_child
     end
 
     # are we paused?
-    def paused?
+    def should_pause?
       @paused
     end
+    alias :paused? :should_pause?
+
+    def pause
+      rd, wr = IO.pipe
+      trap('CONT') {
+        log "CONT received; resuming job processing"
+        @paused = false
+        wr.write 'x'
+        wr.close
+      }
+      rd.read 1
+      rd.close
+    end
 
     # Stop processing jobs after the current one has completed (if we're
     # currently running one).
@@ -325,12 +339,6 @@ def pause_processing
       @paused = true
     end
 
-    # Start processing jobs again after a pause
-    def unpause_processing
-      log "CONT received; resuming job processing"
-      @paused = false
-    end
-
     # Looks for any workers which should be running on this server
     # and, if they're not, removes them from Redis.
     #