From a6c79c7c5a2508e624bddfc39b26218fdbc1bbaa Mon Sep 17 00:00:00 2001
From: David Gobaud <dgobaud@gmail.com>
Date: Wed, 8 Jan 2014 21:25:44 -0500
Subject: [PATCH] monitor children and re-fork when they exit

---
 lib/delayed/tasks.rb | 29 ++++++++++++++++++++++++++++-
 1 file changed, 28 insertions(+), 1 deletion(-)

diff --git a/lib/delayed/tasks.rb b/lib/delayed/tasks.rb
index ce2d075fd..e92bec537 100644
--- a/lib/delayed/tasks.rb
+++ b/lib/delayed/tasks.rb
@@ -6,7 +6,34 @@
 
   desc "Start a delayed_job worker."
   task :work => :environment_options do
-    Delayed::Worker.new(@worker_options).start
+    if @worker_options[:num_processes] == 1
+      Delayed::Worker.new(@worker_options).start
+    else
+      def fork_delayed(worker_index)
+        puts "starting worker #{worker_index}"
+
+        fork do
+          Delayed::Worker.after_fork
+          worker = Delayed::Worker.new(@worker_options)
+          worker.name_prefix = "delayed_job.#{worker_index} "
+          worker.start
+        end
+      end
+
+      Delayed::Worker.before_fork
+      @worker_options[:num_processes].times do |worker_index|
+        fork_delayed(worker_index)
+      end
+
+      worker_index = @worker_options[:num_processes]
+
+      while true do
+        Process.wait()
+
+        fork_delayed(worker_index)
+        worker_index = worker_index + 1
+      end
+    end
   end
 
   desc "Start a delayed_job worker and exit when all available jobs are complete."