Add proper Ractor support to URI

Rakefile

@@ -2,9 +2,16 @@ require "bundler/gem_tasks"
 require "rake/testtask"
 
 Rake::TestTask.new(:test) do |t|
-  t.libs << "test" << "test/lib"
-  t.libs << "lib"
+  t.libs << "test/lib"
+  t.ruby_opts << "-rhelper"
   t.test_files = FileList["test/**/test_*.rb"]
 end
 
+task :sync_tool do
+  require 'fileutils'
+  FileUtils.cp "../ruby/tool/lib/test/unit/core_assertions.rb", "./test/lib"
+  FileUtils.cp "../ruby/tool/lib/envutil.rb", "./test/lib"
+  FileUtils.cp "../ruby/tool/lib/find_executable.rb", "./test/lib"
+end
+
 task :default => :test

lib/uri.rb

@@ -29,8 +29,8 @@
 #   module URI
 #     class RSYNC < Generic
 #       DEFAULT_PORT = 873
-#       URI.refresh_scheme_list
 #     end
+#     register_scheme 'RSYNC', RSYNC
 #   end
 #   #=> URI::RSYNC
 #
@@ -100,3 +100,9 @@ module URI
 require_relative 'uri/ldap'
 require_relative 'uri/ldaps'
 require_relative 'uri/mailto'
+
+module URI
+  INITIAL_SCHEMES = scheme_list
+  private_constant :INITIAL_SCHEMES
+  Ractor.make_shareable(INITIAL_SCHEMES) if defined?(Ractor)
+end

lib/uri/common.rb

@@ -64,38 +64,33 @@ def make_components_hash(klass, array_hash)
 
   include REGEXP
 
-  SCHEME_LIST_MUTEX = Mutex.new
-  private_constant :SCHEME_LIST_MUTEX
-
-  # Returns a Hash of the defined schemes.
-  # The list is lazily calculated.
-  def self.scheme_list
-    return const_get(:SCHEMES) if defined?(SCHEMES)
-
-    SCHEME_LIST_MUTEX.synchronize do
-      const_set(:SCHEMES, ObjectSpace.
-        each_object(Class).
-        select { |klass| klass < URI::Generic }.
-        each_with_object({}) { |klass, acc| acc[klass.name.split('::').last.upcase] = klass }.
-        freeze)
-    end
+  module Schemes
   end
+  private_constant :Schemes
 
-  # Re-calculate scheme list
-  def self.refresh_scheme_list
-    SCHEME_LIST_MUTEX.synchronize do
-      remove_const(:SCHEMES) if defined?(SCHEMES)
-    end
+  def self.register_scheme(scheme, klass)
+    Schemes.const_set(scheme, klass)
+  end
 
-    scheme_list
+  # Returns a Hash of the defined schemes.
+  def self.scheme_list
+    Schemes.constants.map { |name|
+      [name.to_s.upcase, Schemes.const_get(name)]
+    }.to_h
   end
 
   #
   # Construct a URI instance, using the scheme to detect the appropriate class
   # from +URI.scheme_list+.
   #
   def self.for(scheme, *arguments, default: Generic)
-    uri_class = scheme_list[scheme.to_s.upcase] || default
+    const_name = scheme.to_s.upcase
+
+    uri_class = INITIAL_SCHEMES[const_name]
+    if !uri_class && !const_name.empty? && Schemes.const_defined?(const_name, false)
+      uri_class = Schemes.const_get(const_name, false)
+    end
+    uri_class ||= default
 
     return uri_class.new(scheme, *arguments)
   end
@@ -671,6 +666,7 @@ def self.decode_www_form(str, enc=Encoding::UTF_8, separator: '&', use__charset_
     "utf-16"=>"utf-16le",
     "utf-16le"=>"utf-16le",
   } # :nodoc:
+  Ractor.make_shareable(WEB_ENCODINGS_) if defined?(Ractor)
 
   # :nodoc:
   # return encoding or nil

lib/uri/file.rb

@@ -89,4 +89,6 @@ def set_user(v)
     def set_password(v)
     end
   end
+
+  register_scheme 'FILE', File
 end

lib/uri/ftp.rb

@@ -262,4 +262,6 @@ def to_s
       return str
     end
   end
+
+  register_scheme 'FTP', FTP
 end

lib/uri/http.rb

@@ -81,4 +81,6 @@ def request_uri
       url.start_with?(?/.freeze) ? url : ?/ + url
     end
   end
+
+  register_scheme 'HTTP', HTTP
 end

lib/uri/https.rb

@@ -18,4 +18,6 @@ class HTTPS < HTTP
     # A Default port of 443 for URI::HTTPS
     DEFAULT_PORT = 443
   end
+
+  register_scheme 'HTTPS', HTTPS
 end

lib/uri/ldap.rb

@@ -256,4 +256,6 @@ def hierarchical?
       false
     end
   end
+
+  register_scheme 'LDAP', LDAP
 end

lib/uri/ldaps.rb

@@ -17,4 +17,6 @@ class LDAPS < LDAP
     # A Default port of 636 for URI::LDAPS
     DEFAULT_PORT = 636
   end
+
+  register_scheme 'LDAPS', LDAPS
 end

lib/uri/mailto.rb

@@ -288,4 +288,6 @@ def to_mailtext
     end
     alias to_rfc822text to_mailtext
   end
+
+  register_scheme 'MAILTO', MailTo
 end

lib/uri/ws.rb

@@ -78,4 +78,6 @@ def request_uri
       url.start_with?(?/.freeze) ? url : ?/ + url
     end
   end
+
+  register_scheme 'WS', WS
 end

lib/uri/wss.rb

@@ -18,4 +18,6 @@ class WSS < WS
     # A Default port of 443 for URI::WSS
     DEFAULT_PORT = 443
   end
+
+  register_scheme 'WSS', WSS
 end