From 0e3b0fcdba70cf96a8e0654eb8f50aacb8024bd4 Mon Sep 17 00:00:00 2001 From: Samuel Williams Date: Thu, 14 May 2020 22:10:55 +1200 Subject: Thread scheduler for light weight concurrency. --- test/scheduler/test_sleep.rb | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 test/scheduler/test_sleep.rb (limited to 'test/scheduler/test_sleep.rb') diff --git a/test/scheduler/test_sleep.rb b/test/scheduler/test_sleep.rb new file mode 100644 index 0000000000..0be760341e --- /dev/null +++ b/test/scheduler/test_sleep.rb @@ -0,0 +1,30 @@ +# frozen_string_literal: true +require 'test/unit' +require_relative 'scheduler' + +class TestSchedulerSleep < Test::Unit::TestCase + ITEMS = [0, 1, 2, 3, 4] + + def test_sleep + items = [] + + thread = Thread.new do + scheduler = Scheduler.new + Thread.current.scheduler = scheduler + + 5.times do |i| + Fiber do + sleep(i/100.0) + items << i + end + end + + # Should be 5 fibers waiting: + assert_equal scheduler.waiting.size, 5 + end + + thread.join + + assert_equal ITEMS, items + end +end -- cgit v1.2.3