Add idler wip.

lib/async/idler.rb

@@ -0,0 +1,23 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2022, by Samuel Williams.
+
+module Async
+	class Idler
+		def initialize(parent: Task.current)
+			@parent = parent
+			@list = List.new
+		end
+
+		def async(*arguments, parent: (@parent or Task.current), **options)
+			wait
+
+			parent.async(*arguments, **options)
+		end
+
+		def wait
+
+		end
+	end
+end

lib/async/scheduler.rb

@@ -36,10 +36,14 @@ def initialize(parent = nil, selector: nil)
 			@interrupted = false
 
 			@blocked = 0
+			@load = 0
 
 			@timers = ::Timers::Group.new
 		end
 
+		# The load is the number of tasks that were ready to run in the last iteration of the event loop.
+		attr :load
+
 		def scheduler_close
 			# If the execution context (thread) was handling an exception, we want to exit as quickly as possible:
 			unless $!

test.rb

@@ -0,0 +1,33 @@
+#!/usr/bin/env ruby
+
+require_relative 'lib/async'
+
+def measure_load(sample_duration = 1.0)
+	start_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)
+	sleep(sample_duration)
+	duration = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start_time
+
+	return (duration / sample_duration) - 1.0
+end
+
+def add_load(n = 100)
+	n.times do
+		Async do
+			while true
+				sleep 0.01
+			end
+		end
+	end
+end
+
+Async do |task|
+	while true
+		load = measure_load
+		puts "Load: #{sprintf("%0.3f%%", load * 100.0)} children: #{task.children&.size}"
+
+		if load <= 0.01
+			puts "Adding load..."
+			add_load
+		end
+	end
+end