Add Async::Group for straight forward list of children nodes without an associated task.

Author: ioquatix

lib/async/group.rb

@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2019-2022, by Samuel Williams.
+
+require_relative 'list'
+require_relative 'task'
+
+module Async
+	class Group < Node
+		def initialize(parent = Task.current, **options)
+			super(parent, **options)
+		end
+		
+		# Execute a child task and add it to the barrier.
+		# @asynchronous Executes the given block concurrently.
+		def async(*arguments, **options, &block)
+			task = Task.new(self, **options, &block)
+			
+			task.run(*arguments)
+			
+			return task
+		end
+		
+		# Wait for all children tasks to finish.
+		def wait
+			while !finished?
+				Fiber.scheduler.yield
+			end
+		end
+	end
+end

test/async/group.rb

@@ -0,0 +1,25 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2022, by Samuel Williams.
+
+require 'async/group'
+require 'sus/fixtures/async'
+
+describe Async::Group do
+	include Sus::Fixtures::Async::ReactorContext
+	
+	let(:group) {subject.new}
+	
+	it 'can wait for all tasks to finish' do
+		task = group.async do
+			sleep 0.001
+		end
+		
+		expect(task.status).to be == :running
+		
+		group.wait
+		
+		expect(task.status).to be == :complete
+	end
+end