Adopt async-signals graceful defaults. (#68)

Author: samuel-williams-shopify

async-container.gemspec

@@ -25,4 +25,5 @@ Gem::Specification.new do |spec|
 	spec.required_ruby_version = ">= 3.3"
 
 	spec.add_dependency "async", "~> 2.22"
+	spec.add_dependency "async-signals", "~> 0.6"
 end

lib/async/container/controller.rb

@@ -10,6 +10,9 @@
 require_relative "notify"
 require_relative "policy"
 
+# This sets up graceful handling of SIGINT and SIGTERM.
+require "async/signals/graceful"
+
 module Async
 	module Container
 		# The default graceful stop policy for controllers.

test/async/container.rb

@@ -4,8 +4,23 @@
 # Copyright, 2017-2025, by Samuel Williams.
 
 require "async/container"
+require "open3"
+require "rbconfig"
 
 describe Async::Container do
+	def ruby(script)
+		::Open3.capture3(::RbConfig.ruby, "-Ilib", "-e", script)
+	end
+	
+	def expect_success(script)
+		stdout, stderr, status = ruby(script)
+		
+		expect(status).to be(:success?)
+		expect(stderr).to be == ""
+		
+		return stdout
+	end
+	
 	with ".processor_count" do
 		it "can get processor count" do
 			expect(Async::Container.processor_count).to be >= 1
@@ -35,6 +50,46 @@
 		end
 	end
 
+	with "graceful signal defaults" do
+		it "installs graceful SIGINT handling" do
+			stdout = expect_success(<<~RUBY)
+				require "async/container"
+				
+				begin
+					::Thread.handle_interrupt(::Interrupt => :never) do
+						::Process.kill(:INT, ::Process.pid)
+						puts "inner"
+					end
+					
+					sleep 1
+				rescue ::Interrupt
+					puts "outer"
+				end
+			RUBY
+			
+			expect(stdout).to be == "inner\nouter\n"
+		end
+		
+		it "installs graceful SIGTERM handling" do
+			stdout = expect_success(<<~RUBY)
+				require "async/container"
+				
+				begin
+					::Thread.handle_interrupt(::Interrupt => :never) do
+						::Process.kill(:TERM, ::Process.pid)
+						puts "inner"
+					end
+					
+					sleep 1
+				rescue ::Interrupt
+					puts "outer"
+				end
+			RUBY
+			
+			expect(stdout).to be == "inner\nouter\n"
+		end
+	end
+	
 	with ".best" do
 		it "can get the best container class" do
 			expect(Async::Container.best_container_class).not.to be_nil