Skip to content

Commit fe6bc54

Browse files
committed
perf: don't immediately Thread.pass in Pipeline#execute when there is work to do
1 parent ec67558 commit fe6bc54

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

lib/redis_client/cluster/pipeline.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,6 @@ def execute # rubocop:disable Metrics/AbcSize, Metrics/CyclomaticComplexity, Met
142142
@pipelines&.each_slice(MAX_THREADS) do |chuncked_pipelines|
143143
threads = chuncked_pipelines.map do |node_key, pipeline|
144144
Thread.new(node_key, pipeline) do |nk, pl|
145-
Thread.pass
146145
Thread.current.thread_variable_set(:node_key, nk)
147146
replies = do_pipelining(@router.find_node(nk), pl)
148147
raise ReplySizeError, "commands: #{pl._size}, replies: #{replies.size}" if pl._size != replies.size

0 commit comments

Comments
 (0)