Skip to content

Commit 6f3ed77

Browse files
Restore child interrupt mask reset
Assisted-By: devx/3236e566-7538-432e-a30a-2bdf37265ed4
1 parent d1155de commit 6f3ed77

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

lib/async/container/threaded.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,9 @@ def exec(*arguments, ready: true, **options)
114114
def self.fork(**options)
115115
self.new(**options) do |thread|
116116
::Thread.new do
117-
yield Instance.for(thread)
117+
::Thread.handle_interrupt(SignalException => :immediate) do
118+
yield Instance.for(thread)
119+
end
118120
end
119121
end
120122
end

0 commit comments

Comments
 (0)