Usando métodos de control de proceso de Unix en Ruby

Question

Ryan Tomayko provocó una tormenta de fuego con this post sobre el uso de comandos de control de proceso de Unix.

Deberíamos estar haciendo más de esto. Mucho más de esto. Estoy hablando de fork (2), execve (2), pipe (2), socketpair (2), select (2), kill (2), sigaction (2), y así sucesivamente. Estos son nuestros amigos Ellos quieren desesperadamente ayudarnos.

que tienen un poco de código (un clon de delayed_job DataMapper que creo que encajaría perfectamente con esto, pero no me queda claro sobre cómo tomar ventaja de los comandos que aparecen. ¿Alguna idea sobre cómo mejorar este código?

def start 
    say "*** Starting job worker #{@name}" 
    t = Thread.new do 
    loop do 
     delay = Update.work_off(self) 
     break if $exit 
     sleep delay 
     break if $exit 
    end 
    clear_locks 
    end 

    trap('TERM') { terminate_with t } 
    trap('INT') { terminate_with t } 

    trap('USR1') do 
    say "Wakeup Signal Caught" 
    t.run 
    end 
end 

Answer 1

Ahh sí ... los peligros de la "debemos hacer más de esto", sin explicar lo que cada uno de los haces y en qué circunstancias debería usar este recurso. Por algo así como delayed_job incluso se puede esté usando fork sin saber que está usando fork. Dicho esto, realmente no importa. Ryan estaba hablando de usar fork para servidores de prefabricación. delayed_job usaría fork para convertir un proceso en un daemon. Misma llamada al sistema, diferentes propósitos. Ejecutar delayed_job en primer plano (sin fork) vs en el fondo (con fork) dará lugar a una diferencia de rendimiento insignificante.

Sin embargo, si escribe un servidor que acepte conexiones concurrentes, ahora el consejo de Ryan es justo sobre el dinero.

• fork: crea una copia del proceso original
• execve: deja de ejecutar el archivo actual y comienza a ejecutar un nuevo archivo en el mismo proceso (muy útil en tareas rake)
• pipe: crea una canalización (dos descriptores de archivos, uno para lectura, uno para escribir)
• socketpair: como un tubo, pero para tomas
• select: de espera a que uno o más de varios descriptores de fichero dejar que sean leídos y con un tiempo de espera
• kill: se utiliza para enviar una señal a un proceso
• sigaction: le permite cambiar lo que sucede cuando un proceso recibe una señal

Answer 2

5 meses más tarde, puede ver mi solución al http://github.com/antarestrader/Updater . Mira lib/updater/fork_worker.rb