Merge pull request #47736 from rails/thread-safety

Fix Fanout thread safety
rails · Mar 28, 2023 · 689fafa · 689fafa
2 parents e6884f8 + ea2870c
commit 689fafa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/activesupport/lib/active_support/notifications/fanout.rb b/activesupport/lib/active_support/notifications/fanout.rb
@@ -48,7 +48,7 @@ class Fanout
       include Mutex_m
 
       def initialize
-        @string_subscribers = Hash.new { |h, k| h[k] = [] }
+        @string_subscribers = Concurrent::Map.new { |h, k| h[k] = [] }
         @other_subscribers = []
         @all_listeners_for = Concurrent::Map.new
         @groups_for = Concurrent::Map.new