Bug #17678
openRactors do not restart after fork
Description
Hello there! I'm working at Datadog on the ddtrace
gem -- https://github.com/DataDog/dd-trace-rb and we're experimenting with using Ractors in our library but run into a few issues.
Background¶
When running a Ractor as a background process, the Ractor stops & does not restart when the application forks.
How to reproduce (Ruby version & script)¶
ruby 3.0.0p0 (2020-12-25 revision 95aff21468) [x86_64-linux]
r2 = Ractor.new do
loop { puts "[#{Process.pid}] Ractor"; sleep(1) }
end
sleep(1)
puts "[#{Process.pid}] Forking..."
fork do
sleep(5)
puts "[#{Process.pid}] End fork."
end
loop do
sleep(1)
end
Expectation and result¶
The application prints “Ractor” each second in the main process, but not in the fork.
Expected the Ractor (defined as r2
) to run in the fork.
[29] Ractor
[29] Ractor
[29] Forking...
[29] Ractor
[29] Ractor
[29] Ractor
[29] Ractor
[29] Ractor
[32] End fork.
[29] Ractor
[29] Ractor
[29] Ractor
Additional notes¶
Threads do not restart across forks either, so it might not be unreasonable to expect consistent behavior. However, it’s possible to detect a dead Thread and recreate it after a fork (e.g. with #alive?
, #status
), but there’s no such mechanism for Ractors.
Suggested solutions¶
- Auto-restart Ractors after fork
- Add additional methods to Ractors that allow users to check & manage the status of the Ractor, similar to Thread.
Updated by ivoanjo (Ivo Anjo) over 3 years ago
- ruby -v set to ruby 3.0.0p0 (2020-12-25 revision 95aff21468) [x86_64-linux]
Updated by hsbt (Hiroshi SHIBATA) over 3 years ago
- Status changed from Open to Assigned
- Assignee set to ko1 (Koichi Sasada)
Updated by jeremyevans0 (Jeremy Evans) over 1 year ago
- Tracker changed from Bug to Feature
- ruby -v deleted (
ruby 3.0.0p0 (2020-12-25 revision 95aff21468) [x86_64-linux]) - Backport deleted (
2.5: UNKNOWN, 2.6: UNKNOWN, 2.7: UNKNOWN, 3.0: UNKNOWN)
As Ractors always use separate OS threads, and fork only runs the current thread in the forked process, I don't see a way for Ractors to continue where they left off after fork. I think auto-starting would likely be a bad idea, because auto-starting would not return them to the state they were at fork.
The addition of Ractor#alive?
and/or Ractor#status
makes sense to me. Even in non-forked processes such methods could be useful. Note that you can get what you want already, by calling Ractor#inspect
, so these methods would only need to expose information that Ractor is already storing.
Updated by ivoanjo (Ivo Anjo) over 1 year ago
The addition of Ractor#alive? and/or Ractor#status makes sense to me. Even in non-forked processes such methods could be useful. Note that you can get what you want already, by calling Ractor#inspect, so these methods would only need to expose information that Ractor is already storing.
Thanks for looking into this!
I don't think the info is there in #inspect... At least I don't get it on stable or latest ruby-head? 😅
Here's an updated example:
puts RUBY_DESCRIPTION
r2 = Ractor.new { puts "[#{Process.pid}] Ractor started!"; sleep(1000) }
puts "[#{Process.pid}] In parent process, ractor status is #{r2.inspect}"
sleep(1)
puts "[#{Process.pid}] Forking..."
fork do
puts "[#{Process.pid}] In child process, ractor status is #{r2.inspect}"
end
Process.wait
and here's what I get:
$ ruby ractor-test.rb
ruby 3.3.0dev (2023-08-24T12:12:51Z master 5ec1fc52c1) [x86_64-linux]
ractor-test.rb:3: warning: Ractor is experimental, and the behavior may change in future versions of Ruby! Also there are many implementation issues.
[10] In parent process, ractor status is #<Ractor:#2 ractor-test.rb:3 blocking>
[10] Ractor started!
[10] Forking...
[12] In child process, ractor status is #<Ractor:#2 ractor-test.rb:3 blocking>
Updated by jeremyevans0 (Jeremy Evans) over 1 year ago
- Tracker changed from Feature to Bug
- Backport set to 3.0: UNKNOWN, 3.1: UNKNOWN, 3.2: UNKNOWN
Thanks for that information. It looks like ractors contain information about their state (shown in inspect
), but that state is not updated on fork, unlike threads. So I think there is a bug, and it's that non-main ractors do not have their state to terminated
upon fork (forking from non-main ractors is going to be prohibited, see #17516).
Updated by ivoanjo (Ivo Anjo) over 1 year ago
Ack, that seems a reasonable way of looking at this, having a way to detect that the ractor is dead would be enough to write some auto-restart code after fork (Erlang supervisor trees here we go :D).
Updated by jeremyevans0 (Jeremy Evans) over 1 year ago
I updated https://github.com/ruby/ruby/pull/8283 to mark non-main ractors as terminated after fork.