Add Sidekiq::Launcher, extracted from Sidekiq::CLI.

This is a step forward to run Sidekiq inside a process,
making it more easily to integrate into existing process.

lib/sidekiq/cli.rb

@@ -18,7 +18,7 @@ end
 
 trap 'USR1' do
   Sidekiq.logger.info "Received USR1, no longer accepting new work"
-  mgr = Sidekiq::CLI.instance.manager
+  mgr = Sidekiq::CLI.instance.launcher.manager
   mgr.async.stop if mgr
 end
 
@@ -49,6 +49,7 @@ require 'erb'
 
 require 'sidekiq'
 require 'sidekiq/util'
+require 'sidekiq/launcher'
 
 module Sidekiq
   class CLI
@@ -57,7 +58,7 @@ module Sidekiq
 
     # Used for CLI testing
     attr_accessor :code
-    attr_accessor :manager
+    attr_accessor :launcher
     attr_accessor :environment
 
     def initialize
@@ -89,21 +90,18 @@ module Sidekiq
         logger.info 'Starting processing, hit Ctrl-C to stop'
       end
 
-      @manager = Sidekiq::Manager.new(options)
+      @launcher = Sidekiq::Launcher.new(options)
-      poller = Sidekiq::Scheduled::Poller.new
+
       begin
         if options[:profile]
           require 'ruby-prof'
           RubyProf.start
         end
-        @manager.async.start
+        launcher.run
-        poller.async.poll(true)
         sleep
       rescue Interrupt
         logger.info 'Shutting down'
-        poller.async.terminate if poller.alive?
+        launcher.stop
-        @manager.async.stop(:shutdown => true, :timeout => options[:timeout])
-        @manager.wait(:shutdown)
         # Explicitly exit so busy Processor threads can't block
         # process shutdown.
         exit(0)

lib/sidekiq/launcher.rb

@@ -0,0 +1,26 @@
+
+require 'sidekiq/util'
+require 'sidekiq/manager'
+require 'sidekiq/scheduled'
+
+module Sidekiq
+  class Launcher
+    attr_reader :manager, :poller, :options
+    def initialize(options)
+      @options = options
+      @manager = Sidekiq::Manager.new(options)
+      @poller  = Sidekiq::Scheduled::Poller.new
+    end
+
+    def run
+      manager.async.start
+      poller.async.poll(true)
+    end
+
+    def stop
+      poller.async.terminate if poller.alive?
+      manager.async.stop(:shutdown => true, :timeout => options[:timeout])
+      manager.wait(:shutdown)
+    end
+  end
+end