Modernize code.

Author: ioquatix

.mailmap

@@ -8,3 +8,4 @@ Leon Löchner <leonloechner@gmx.de> <60091705+leonnicolas@users.noreply.github.c
 Math Ieu <sigsys@gmail.com>
 Shopify Inc. <samuel.williams@shopify.com>
 Shigeru Nakajima <shigeru.nakajima@gmail.com>
+Yuhi Sato <yuhi120101@gmail.com>

.rubocop.yml

@@ -1,12 +1,23 @@
 plugins:
+  - rubocop-md
   - rubocop-socketry
 
 AllCops:
   DisabledByDefault: true
 
+# Socketry specific rules:
+
 Layout/ConsistentBlankLineIndentation:
   Enabled: true
 
+Layout/BlockDelimiterSpacing:
+  Enabled: true
+
+Style/GlobalExceptionVariables:
+  Enabled: true
+
+# General Layout rules:
+
 Layout/IndentationStyle:
   Enabled: true
   EnforcedStyle: tabs
@@ -33,6 +44,9 @@ Layout/BeginEndAlignment:
   Enabled: true
   EnforcedStyleAlignWith: start_of_line
 
+Layout/RescueEnsureAlignment:
+  Enabled: true
+
 Layout/ElseAlignment:
   Enabled: true
 
@@ -41,10 +55,15 @@ Layout/DefEndAlignment:
 
 Layout/CaseIndentation:
   Enabled: true
+  EnforcedStyle: end
 
 Layout/CommentIndentation:
   Enabled: true
 
+Layout/FirstHashElementIndentation:
+  Enabled: true
+  EnforcedStyle: consistent
+
 Layout/EmptyLinesAroundClassBody:
   Enabled: true
 

async.gemspec

@@ -7,7 +7,7 @@ Gem::Specification.new do |spec|
 	spec.version = Async::VERSION
 
 	spec.summary = "A concurrency framework for Ruby."
-	spec.authors = ["Samuel Williams", "Shopify Inc.", "Bruno Sutic", "Jeremy Jung", "Olle Jonsson", "Patrik Wenger", "Devin Christensen", "Emil Tin", "Jamie McCarthy", "Kent Gruber", "Alan Wu", "Brian Morearty", "Colin Kelley", "Dimitar Peychinov", "Gert Goet", "Jahfer Husain", "Jatin Goyal", "Jiang Jinyang", "Josh Teeter", "Julien Portalier", "Jun Jiang", "Ken Muryoi", "Leon Löchner", "Mark Montroy", "Masafumi Okura", "Masayuki Yamamoto", "Math Ieu", "Ryan Musgrave", "Salim Semaoune", "Shannon Skipper", "Shigeru Nakajima", "Sokolov Yura", "Stefan Wrobel", "Trevor Turk"]
+	spec.authors = ["Samuel Williams", "Shopify Inc.", "Bruno Sutic", "Jeremy Jung", "Olle Jonsson", "Patrik Wenger", "Devin Christensen", "Emil Tin", "Jamie McCarthy", "Kent Gruber", "Alan Wu", "Brian Morearty", "Colin Kelley", "Dimitar Peychinov", "Gert Goet", "Jahfer Husain", "Jatin Goyal", "Jiang Jinyang", "Josh Teeter", "Julien Portalier", "Jun Jiang", "Ken Muryoi", "Leon Löchner", "Mark Montroy", "Masafumi Okura", "Masayuki Yamamoto", "Math Ieu", "Ryan Musgrave", "Salim Semaoune", "Shannon Skipper", "Shigeru Nakajima", "Sokolov Yura", "Stefan Wrobel", "Trevor Turk", "Yuhi Sato"]
 	spec.license = "MIT"
 
 	spec.cert_chain  = ["release.cert"]

benchmark/condition.rb

@@ -128,15 +128,15 @@
 
 				Async do |task|
 					# Check empty state
-					100.times {test_condition.empty?}
+					100.times{test_condition.empty?}
 
 					# Create a waiter
 					waiter = task.async do
 						test_condition.wait
 					end
 
 					# Check waiting state
-					100.times {test_condition.waiting?}
+					100.times{test_condition.waiting?}
 
 					# Signal to complete
 					test_condition.signal("done")
@@ -188,7 +188,7 @@
 					# Producer
 					producer = task.async do
 						ready_condition.wait # Wait for consumer to be ready
-						50.times {|i| "item-#{i}"} # Simulate work
+						50.times{|i| "item-#{i}"} # Simulate work
 						done_condition.signal("finished")
 					end
 
@@ -211,7 +211,7 @@
 				test_condition = Async::Condition.new
 
 				Async do |task|
-					waiter = task.async {test_condition.wait}
+					waiter = task.async{test_condition.wait}
 
 					test_condition.signal("cleanup")
 					waiter.wait

benchmark/queue.rb

@@ -28,10 +28,10 @@
 			repeats.times do
 				Async do
 					# Create a batch of 100 items each time
-					items = Array.new(100) {|i| "item-#{i}"}
+					items = Array.new(100){|i| "item-#{i}"}
 					queue.enqueue(*items)
 					# Clear queue for next iteration
-					100.times {queue.dequeue}
+					100.times{queue.dequeue}
 				end
 			end
 		end
@@ -40,7 +40,7 @@
 			repeats.times do
 				Async do
 					# Pre-populate queue with 100 items
-					items = Array.new(100) {|i| "item-#{i}"}
+					items = Array.new(100){|i| "item-#{i}"}
 					queue.enqueue(*items)
 
 					# Measure dequeue operations
@@ -119,7 +119,7 @@
 							queue.push("item-#{i}")
 						end
 						# Signal completion to all consumers
-						num_consumers.times {queue.push(nil)}
+						num_consumers.times{queue.push(nil)}
 					end
 
 					# Multiple consumers
@@ -145,7 +145,7 @@
 			repeats.times do
 				Async do |task|
 					# Pre-populate with some items
-					100.times {|i| queue.push("item-#{i}")}
+					100.times{|i| queue.push("item-#{i}")}
 
 					# Check state frequently
 					size_checker = task.async do
@@ -166,7 +166,7 @@
 					[size_checker, modifier].each(&:wait)
 
 					# Clean up
-					queue.size.times {queue.dequeue}
+					queue.size.times{queue.dequeue}
 				end
 			end
 		end
@@ -178,7 +178,7 @@
 
 				Async do
 					# Fill queue
-					50.times {|i| test_queue.push("item-#{i}")}
+					50.times{|i| test_queue.push("item-#{i}")}
 
 					# Close it
 					test_queue.close
@@ -197,16 +197,16 @@
 			repeats.times do
 				Async do
 					# Fill the queue
-					100.times {|i| queue.push("item-#{i}")}
+					100.times{|i| queue.push("item-#{i}")}
 
 					# Empty the queue  
-					100.times {queue.dequeue}
+					100.times{queue.dequeue}
 
 					# Fill again to test reuse
-					100.times {|i| queue.push("item-#{i}")}
+					100.times{|i| queue.push("item-#{i}")}
 
 					# Empty again
-					100.times {queue.dequeue}
+					100.times{queue.dequeue}
 				end
 			end
 		end

benchmark/rubies/benchmark.rb

@@ -194,7 +194,7 @@ def write(buffer)
 	workers.push f
 end
 
-workers.each {|f| f.resume}
+workers.each{|f| f.resume}
 
 master_fiber = Fiber.new do
 	NUM_WORKERS.times do |worker_num|

benchmark/task.rb

@@ -15,7 +15,7 @@
 		measure "simple task creation and completion" do |repeats|
 			Async do |task|
 				repeats.times do
-					child = task.async {"result"}
+					child = task.async{"result"}
 					child.wait
 				end
 			end
@@ -51,7 +51,7 @@
 		measure "wait on immediately completing tasks" do |repeats|
 			Async do |task|
 				repeats.times do
-					child = task.async {"result"}
+					child = task.async{"result"}
 					child.wait
 				end
 			end
@@ -74,7 +74,7 @@
 			completed_tasks = []
 			Async do |task|
 				100.times do
-					completed_tasks << task.async {"completed"}
+					completed_tasks << task.async{"completed"}
 				end
 
 				# Wait for all to complete

benchmark/timers/after_0.rb

@@ -2,7 +2,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2024, by Samuel Williams.
+# Copyright, 2024-2025, by Samuel Williams.
 
 require "benchmark/ips"
 
@@ -17,7 +17,7 @@
 		timers = Timers::Group.new
 
 		while count > 0
-			timers.after(0) {count -= 1}
+			timers.after(0){count -= 1}
 			timers.fire
 		end
 	end
@@ -26,7 +26,7 @@
 		timers = IO::Event::Timers.new
 
 		while count > 0
-			timers.after(0) {count -= 1}
+			timers.after(0){count -= 1}
 			timers.fire
 		end
 	end

benchmark/timers/after_cancel.rb

@@ -2,7 +2,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2024, by Samuel Williams.
+# Copyright, 2024-2025, by Samuel Williams.
 
 require "benchmark/ips"
 
@@ -17,7 +17,7 @@
 		timers = Timers::Group.new
 
 		while count > 0
-			timer = timers.after(0) {}
+			timer = timers.after(0){}
 			timer.cancel
 			count -= 1
 		end
@@ -29,7 +29,7 @@
 		timers = IO::Event::Timers.new
 
 		while count > 0
-			timer = timers.after(0) {}
+			timer = timers.after(0){}
 			timer.cancel!
 			count -= 1
 		end

benchmark/timers/after_n.rb

@@ -2,7 +2,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2024, by Samuel Williams.
+# Copyright, 2024-2025, by Samuel Williams.
 
 require "benchmark/ips"
 
@@ -17,7 +17,7 @@
 		timers = Timers::Group.new
 
 		while count > 0
-			timers.after(0) {}
+			timers.after(0){}
 			count -= 1
 		end
 
@@ -28,7 +28,7 @@
 		timers = IO::Event::Timers.new
 
 		while count > 0
-			timers.after(0) {}
+			timers.after(0){}
 			count -= 1
 		end