Modernize code + RuboCop.

Author: ioquatix

.gitignore

@@ -1,4 +1,5 @@
 /.bundle
+/.context
 /pkg
 /gems.locked
 /.covered.db

.rubocop.yml

@@ -1,6 +1,12 @@
+plugins:
+  - rubocop-socketry
+
 AllCops:
   DisabledByDefault: true
 
+Layout/ConsistentBlankLineIndentation:
+  Enabled: true
+
 Layout/IndentationStyle:
   Enabled: true
   EnforcedStyle: tabs

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", "Bruno Sutic", "Jeremy Jung", "Olle Jonsson", "Patrik Wenger", "Devin Christensen", "Shopify Inc.", "Emil Tin", "Jamie McCarthy", "Kent Gruber", "Alan Wu", "Brian Morearty", "Colin Kelley", "Dimitar Peychinov", "Gert Goet", "Jahfer Husain", "Jiang Jinyang", "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", "Jiang Jinyang", "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.license = "MIT"
 
 	spec.cert_chain  = ["release.cert"]

benchmark/rubies/benchmark.rb

@@ -2,7 +2,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2019-2024, by Samuel Williams.
+# Copyright, 2019-2025, by Samuel Williams.
 
 require "socket"
 require "fiber"
@@ -33,27 +33,27 @@ def initialize
 		@readable = {}
 		@writable = {}
 	end
-
+	
 	def run
 		while @readable.any? or @writable.any?
 			readable, writable = IO.select(@readable.keys, @writable.keys, [])
-
+			
 			readable.each do |io|
 				@readable[io].resume
 			end
-
+			
 			writable.each do |io|
 				@writable[io].resume
 			end
 		end
 	end
-
+	
 	def wait_readable(io)
 		@readable[io] = Fiber.current
 		Fiber.yield
 		@readable.delete(io)
 	end
-
+	
 	def wait_writable(io)
 		@writable[io] = Fiber.current
 		Fiber.yield
@@ -79,7 +79,7 @@ def read_nonblock(length, buffer)
 					return result
 				end
 			end
-
+			
 		end
 
 		def write_nonblock(buffer)
@@ -173,7 +173,7 @@ def write(buffer)
 	r, w = IO.pipe
 	worker_read.push Wrapper.new(r, reactor)
 	master_write.push Wrapper.new(w, reactor)
-
+	
 	r, w = IO.pipe
 	worker_write.push Wrapper.new(w, reactor)
 	master_read.push Wrapper.new(r, reactor)

examples/capture/capture.rb

@@ -109,7 +109,7 @@ def strace(pid, duration = 60)
 	if total = summary[:total]
 		process_duration = end_times.utime - start_times.utime
 		wait_duration = summary[:total][:seconds]
-	
+		
 		Console.info("Process Waiting: #{wait_duration.round(4)}s out of #{process_duration.round(4)}s") do |buffer|
 			buffer.puts "Wait percentage: #{(wait_duration / process_duration * 100.0).round(2)}%"
 		end

examples/dining-philosophers/philosophers.rb

@@ -13,19 +13,19 @@ def initialize(name, left_fork, right_fork)
 		@left_fork = left_fork
 		@right_fork = right_fork
 	end
-
+	
 	def think
 		puts "#{@name} is thinking."
 		sleep(rand(1..3))
 		puts "#{@name} has finished thinking."
 	end
-
+	
 	def eat
 		puts "#{@name} is eating."
 		sleep(rand(1..3))
 		puts "#{@name} has finished eating."
 	end
-
+	
 	def dine
 		Sync do |task|
 			think

examples/load/test.rb

@@ -24,7 +24,7 @@
 	scheduler = Fiber.scheduler
 	while true
 		load = scheduler.load
-
+		
 		$stdout.write "\nLoad: #{load} "
 		sleep 1.0
 	end

fixtures/async/a_queue.rb

@@ -77,11 +77,11 @@ module Async
 
 		it "can enqueue multiple items" do
 			items = Array.new(10) {rand(10)}
-
+			
 			reactor.async do |task|
 				queue.enqueue(*items)
 			end
-
+			
 			items.each do |item|
 				expect(queue.dequeue).to be == item
 			end
@@ -130,15 +130,15 @@ module Async
 				expect(queue.wait).to be == :item
 			end
 		end
-
+		
 		with "#close" do
 			it "signals waiting tasks when closed" do
 				waiting_task = reactor.async do
 					queue.dequeue
 				end
-
+				
 				queue.close
-
+				
 				waiting_task.wait
 				expect(waiting_task).to be(:finished?)
 			end
@@ -188,37 +188,37 @@ module Async
 				expect(count).to be == repeats
 			end
 		end
-
+		
 		with "a closed queue" do
 			before do
 				queue.close
 			end
-
+			
 			it "prevents push after close" do
 				expect{queue.push(:item)}.to raise_exception(Async::Queue::ClosedError)
 			end
-
+			
 			it "prevents enqueue after close" do
 				expect{queue.enqueue(:item)}.to raise_exception(Async::Queue::ClosedError)
 			end
-
+			
 			it "prevents << after close" do
 				expect{queue << :item}.to raise_exception(Async::Queue::ClosedError)
 			end
-
+			
 			it "returns nil from dequeue when closed and empty" do
 				expect(queue.dequeue).to be_nil
 			end
-
+			
 			it "returns nil from pop when closed and empty" do
 				expect(queue.pop).to be_nil
 			end
-
+			
 			it "signals waiting tasks when closed" do
 				waiting_task = reactor.async do
 					queue.dequeue
 				end
-
+				
 				# Already closed, so just check if the task finishes:
 				waiting_task.wait
 				expect(waiting_task).to be(:finished?)

gems.rb

@@ -30,7 +30,9 @@
 	gem "sus", "~> 0.31"
 	gem "covered"
 	gem "decode"
+	
 	gem "rubocop"
+	gem "rubocop-socketry"
 
 	gem "sus-fixtures-async"
 	gem "sus-fixtures-console"

lib/async/condition.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2017-2024, by Samuel Williams.
+# Copyright, 2017-2025, by Samuel Williams.
 # Copyright, 2017, by Kent Gruber.
 
 require "fiber"