jaki jest właściwy sposób na obsługę limitów czasu dla aktywnego rekordu z pulą połączeń?

Question

Wyszukałem dziwny błąd undefined method `run_callbacks' for nil:NilClass i udało się go odtworzyć za pomocą tego przykładowego kodu.

Zasadniczo problem polega na tym, że aktywnym rekordem jest przekroczenie limitu czasu (domyślnie 5s), ale wyrzucenie nieokreślonego wyjątku metody, co wydaje mi się błędne.

Ale w każdym razie, jaki jest właściwy sposób, aby sobie z tym poradzić? W moim prawdziwym kodzie, mam kilka wątków, które są zajęte wykonywaniem prawdziwej pracy, ale czasami trafiam ten błąd. Wyobraź sobie, że kod puts jest prawdziwy. Chcę, aby istniejące wątki dalej działały, kiedy to się stanie.

threads = [] 
10.times do |n| 

threads << Thread.new { 
    ActiveRecord::Base.connection_pool.with_connection do |conn| 
     puts "#{n} #{conn}" 
     res = conn.execute("select sleep(6)", :async => true) 
    end 
    } 
end 

# block and wait for all threads to finish 
threads.each { |t| puts "joined" ; t.join } 
rescue Exception => e 
    puts $!, $@ 
end 

Jeśli uruchomię ten kod, otrzymuję wyjątek. Jeśli zmniejszę sen do 4s, nie. Oto wynik ze snu 6s.

joined 
0 #<ActiveRecord::ConnectionAdapters::Mysql2Adapter:0xb73c6380> 
1 #<ActiveRecord::ConnectionAdapters::Mysql2Adapter:0xb73c5548> 
2 #<ActiveRecord::ConnectionAdapters::Mysql2Adapter:0xb73c4fe4> 
3 #<ActiveRecord::ConnectionAdapters::Mysql2Adapter:0xb73c4a80> 
4 #<ActiveRecord::ConnectionAdapters::Mysql2Adapter:0xb73c451c> 
joined 
joined 
joined 
joined 
joined 
undefined method `run_callbacks' for nil:NilClass 
/usr/lib/ruby/gems/1.8/gems/activerecord-2.2.2/lib/active_record/connection_adapters/abstract/connection_pool.rb:212:in `checkin' 
sqltst.rb:31:in `join' 
sqltst.rb:31 
sqltst.rb:31:in `each' 
sqltst.rb:31 

Answer 1

W tym obszarze wykonano wiele prac związanych z ActiveRecord od opublikowania tego pytania. Oto kilka dobrych wyjaśnień: http://bibwild.wordpress.com/2012/03/15/activerecord-concurrency-currently-good-news-and-bad/

Answer 2

Powinieneś ustawić pulę: 10 w pliku database.yml. Wygląda na to, że osiągnąłeś limit.