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_io.rb | 35 +++++++++++++++++++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 test/scheduler/test_io.rb (limited to 'test/scheduler/test_io.rb') diff --git a/test/scheduler/test_io.rb b/test/scheduler/test_io.rb new file mode 100644 index 0000000000..ef46d1ac2c --- /dev/null +++ b/test/scheduler/test_io.rb @@ -0,0 +1,35 @@ +# frozen_string_literal: true +require 'test/unit' +require_relative 'scheduler' + +class TestSchedulerIO < Test::Unit::TestCase + MESSAGE = "Hello World" + + def test_read + skip unless defined?(UNIXSocket) + + i, o = UNIXSocket.pair + skip unless i.nonblock? && o.nonblock? + + message = nil + + thread = Thread.new do + scheduler = Scheduler.new + Thread.current.scheduler = scheduler + + Fiber do + message = i.read(20) + i.close + end + + Fiber do + o.write("Hello World") + o.close + end + end + + thread.join + + assert_equal MESSAGE, message + end +end -- cgit v1.2.3