Skip to content

Commit 2981dda

Browse files
authored
Merge pull request #151 from matthewshafer/pipeline-execute-no-thread-pass
perf: don't immediately Thread.pass in Pipeline#execute when there is work to do
2 parents ec67558 + fe6bc54 commit 2981dda

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)