test: add a case for Ractor

Author: supercaracal

test/test_concurrency.rb

@@ -132,6 +132,75 @@ def test_threading_with_transaction
     assert_equal(WANT, @client.call('GET', '{key}1'))
   end
 
+  def test_ractor
+    skip('Ractor is not available') unless Object.const_defined?(:Ractor, false)
+
+    ractors = Array.new(MAX_THREADS) do |i|
+      Ractor.new(i) do |i|
+        c = ::RedisClient.cluster(
+          nodes: TEST_NODE_URIS,
+          fixed_hostname: TEST_FIXED_HOSTNAME,
+          **TEST_GENERIC_OPTIONS
+        ).new_client
+        c.call('get', "key#{i}")
+      rescue StandardError => e
+        e
+      ensure
+        c&.close
+      end
+    end
+
+    ractors.each { |r| assert_equal(WANT, r.take) }
+  end
+
+  def test_ractor_with_pipelining
+    skip('Ractor is not available') unless Object.const_defined?(:Ractor, false)
+
+    ractors = Array.new(MAX_THREADS) do |i|
+      Ractor.new(i) do |i|
+        c = ::RedisClient.cluster(
+          nodes: TEST_NODE_URIS,
+          fixed_hostname: TEST_FIXED_HOSTNAME,
+          **TEST_GENERIC_OPTIONS
+        ).new_client
+        c.pipelined do |pi|
+          pi.call('get', "key#{i}")
+          pi.call('get', "key#{i}")
+        end
+      rescue StandardError => e
+        e
+      ensure
+        c&.close
+      end
+    end
+
+    ractors.each { |r| assert_equal([WANT, WANT], r.take) }
+  end
+
+  def test_ractor_with_transaction
+    skip('Ractor is not available') unless Object.const_defined?(:Ractor, false)
+
+    ractors = Array.new(MAX_THREADS) do |i|
+      Ractor.new(i) do |i|
+        c = ::RedisClient.cluster(
+          nodes: TEST_NODE_URIS,
+          fixed_hostname: TEST_FIXED_HOSTNAME,
+          **TEST_GENERIC_OPTIONS
+        ).new_client
+        c.multi(watch: ["key#{i}"]) do |tx|
+          tx.call('incr', "key#{i}")
+          tx.call('incr', "key#{i}")
+        end
+      rescue StandardError => e
+        e
+      ensure
+        c&.close
+      end
+    end
+
+    ractors.each { |r| assert_equal([2, 3], r.take) }
+  end
+
   private
 
   def new_test_client

test/testing_constants.rb

@@ -76,6 +76,8 @@
   raise NotImplementedError, TEST_REDIS_HOST
 end
 
+Ractor.make_shareable(TEST_NODE_URIS) if Object.const_defined?(:Ractor, false) && Ractor.respond_to?(:make_shareable)
+
 TEST_GENERIC_OPTIONS = (TEST_REDIS_SSL ? _base_opts.merge(_ssl_opts) : _base_opts).freeze
 
 _tmp_cli = _new_raw_cli.call(**TEST_GENERIC_OPTIONS)