Fix various race conditions in test with io_uring.

Author: ioquatix

test/async/barrier.rb

@@ -18,29 +18,22 @@
 
 	with "#async" do
 		let(:repeats) {40}
-		let(:delay) {0.01}
 
 		it "should wait for all jobs to complete" do
 			finished = 0
 
 			repeats.times.map do |i|
 				barrier.async do |task|
-					sleep(delay)
+					task.yield
 					finished += 1
-					
-					# This task is a child task but not part of the barrier.
-					task.async do
-						sleep(delay*3)
-					end
 				end
 			end
 
 			expect(barrier).not.to be(:empty?)
-			expect(finished).to be < repeats
+			expect(finished).to be <= repeats
 
-			duration = Async::Clock.measure{barrier.wait}
+			barrier.wait
 
-			expect(duration).to be_within(repeats * Sus::Fixtures::Time::QUANTUM).of(delay)
 			expect(finished).to be == repeats
 			expect(barrier).to be(:empty?)
 		end

test/async/limited_queue.rb

@@ -87,17 +87,16 @@ def before
 	with "#close" do
 		it "signals tasks waiting to enqueue items when closed" do
 			queue.enqueue(:item1)
-
+			
 			# This task will block as the queue is full:
 			waiting_task = reactor.async do
-				queue.enqueue(:item2)
+				expect do
+					queue.enqueue(:item2)
+				end.to raise_exception(Async::Queue::ClosedError)
 			end
-
+			
 			queue.close
-
-			expect do
-				waiting_task.wait
-			end.to raise_exception(Async::Queue::ClosedError)
+			waiting_task.wait
 		end
 	end
 end

test/async/notification.rb

@@ -31,7 +31,6 @@
 
 		expect(task.status).to be == :running
 
-		sequence << :yielding
 		reactor.yield
 		sequence << :finished
 
@@ -41,7 +40,6 @@
 			:waiting,
 			:running,
 			:signalled,
-			:yielding,
 			:resumed,
 			:finished
 		]

test/io.rb

@@ -101,7 +101,7 @@
 			read_task = Async do
 				expect do
 					r.read(5)
-				end.to raise_exception(IOError, message: be =~ /stream closed/)
+				end.to raise_exception(IOError, message: be =~ /closed/)
 			end
 
 			r.close
@@ -116,7 +116,7 @@
 			read_task = Async do
 				expect do
 					r.read(5)
-				end.to raise_exception(IOError, message: be =~ /stream closed/)
+				end.to raise_exception(IOError, message: be =~ /closed/)
 			end
 
 			close_task = Async do
@@ -135,7 +135,7 @@
 			read_task = Async do
 				expect do
 					r.read(5)
-				end.to raise_exception(IOError, message: be =~ /stream closed/)
+				end.to raise_exception(IOError, message: be =~ /closed/)
 			end
 
 			close_thread = Thread.new do
@@ -154,7 +154,7 @@
 			read_task = Async do
 				expect do
 					r.read(5)
-				end.to raise_exception(IOError, message: be =~ /stream closed/)
+				end.to raise_exception(IOError, message: be =~ /closed/)
 			end
 
 			close_thread = Thread.new do