fix: race condition with interruptibles (#566)

* fix: race condition with interruptibles

* fix: make attr_reader private

Author: elasticspoon

lib/solid_queue/processes/base.rb

@@ -4,7 +4,8 @@ module SolidQueue
   module Processes
     class Base
       include Callbacks # Defines callbacks needed by other concerns
-      include AppExecutor, Registrable, Interruptible, Procline
+      include AppExecutor, Registrable, Procline
+      prepend Interruptible
 
       attr_reader :name
 

lib/solid_queue/processes/interruptible.rb

@@ -2,13 +2,20 @@
 
 module SolidQueue::Processes
   module Interruptible
+    def initialize(...)
+      super
+      @self_pipe = create_self_pipe
+    end
+
     def wake_up
       interrupt
     end
 
     private
       SELF_PIPE_BLOCK_SIZE = 11
 
+      attr_reader :self_pipe
+
       def interrupt
         self_pipe[:writer].write_nonblock(".")
       rescue Errno::EAGAIN, Errno::EINTR
@@ -25,10 +32,6 @@ def interruptible_sleep(time)
       end
 
       # Self-pipe for signal-handling (http://cr.yp.to/docs/selfpipe.html)
-      def self_pipe
-        @self_pipe ||= create_self_pipe
-      end
-
       def create_self_pipe
         reader, writer = IO.pipe
         { reader: reader, writer: writer }