Używanie uniksowych metod sterowania procesami w Rubim

Question

Ryan Tomayko poruszył burzę ogniową z this post o użyciu poleceń sterujących procesem Unix.

Powinniśmy robić więcej tego. O wiele więcej. Mówię o fork (2), execve (2), pipe (2), socketpair (2), select (2), kill (2), sigaction (2), i tak dalej i tak dalej. To są nasi przyjaciele. Tak bardzo chcą nam tylko pomóc.

Mam bitowego kodu (a delayed_job klona dla DataMapper myślę że pasowałby rację z tym, ale nie jestem jasne, w jaki sposób skorzystać z wymienionych poleceń. Wszelkie pomysły jak poprawić ten kod?

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 tak ... niebezpieczeństwa „Musimy zrobić więcej tego”, nie wyjaśniając, co każdy z tych czy iw jakich okolicznościach pan by ich używać. na coś podobnego delayed_job może nawet używać fork nie wiedząc, że używasz fork. Powiedziałeś, że to naprawdę nie ma znaczenia, Ryan mówił o używaniu fork dla serwerów preforkujących. delayed_job użyłby fork do przekształcenia procesu w demona. Takie same wywołania systemowe, różne cele. Uruchamianie delayed_job na pierwszym planie (bez fork) w tle (z fork) spowoduje nieznaczną różnicę w wydajności.

Jednak, jeśli napiszesz serwer, który akceptuje równoczesne połączenia, teraz rada Ryana jest odpowiednia dla pieniędzy.

• fork: tworzy kopię oryginału procesu
• execve: zatrzymuje wykonywany bieżącego pliku i rozpoczyna wykonywanie nowego pliku w tym samym procesie (bardzo użyteczne w zadaniach natarcia)
• pipe: tworzy rurę (dwa deskryptory plików, po jednym dla odczytu, jeden dla zapisu)
• socketpair: jak rury, ale dla gniazd
• select: niech poczekać na jedną lub więcej z wielu deskryptorów plików do odczytu y z timeout
• kill: służy do wysyłania sygnału do procesu
• sigaction: pozwala zmienić to, co się dzieje, gdy proces otrzyma sygnał

Answer 2

5 miesięcy później, można zobaczyć moje rozwiązanie w http://github.com/antarestrader/Updater . Spójrz na lib/updater/fork_worker.rb