ActiveRecord连接过期报错排查：多线程环境连接归属异常

使用concurrent-ruby库的ThreadPoolExecutor编写多线程代码如下：

pool.post do
  ActiveRecord::Base.connection_pool.with_connection do
     process
  end
end

执行时出现报错：

ActiveRecord::ActiveRecordError: Cannot expire connection, it is owned by a different thread:

改为顺序执行则无报错，进一步排查发现存在已死亡线程：

#owner of connection
#<Thread:0x000000012026baa8 /Users/.rbenv/versions/3.2.0/lib/ruby/gems/3.2.0/gems/concurrent-ruby-1.2.2/lib/concurrent-ruby/concurrent/executor/ruby_thread_pool_executor.rb:333 dead> 

# current thread
#<Thread:0x0000000104a2b110 run>

疑问：每个线程应获取独立数据库连接，为何出现该问题？线程死亡的原因是什么？如何解决？

可能的原因 #

1. 线程意外死亡导致连接未释放
   线程池中的线程如果因未捕获的异常崩溃，with_connection的连接释放逻辑（依赖代码块的ensure机制）会失效，连接被永久标记为属于已死亡的线程。后续连接池尝试复用或回收该连接时，就会触发归属不匹配的错误。

2. 线程复用与连接归属冲突
   ThreadPoolExecutor会复用线程，若之前的线程异常退出时未清理连接关联，新任务复用该线程时，连接池的线程-连接映射会出现混乱，导致后续任务无法正常获取/释放连接。

3. process方法存在未捕获异常
   如果process抛出未被捕获的异常，会直接终止线程池中的线程，跳过with_connection的连接释放步骤，造成连接泄漏并关联到已死亡线程。

解决方案 #

1. 捕获所有异常，确保连接正常释放 #

在任务块内添加异常捕获，保证无论是否出错，连接都能被归还到连接池：

pool.post do
  begin
    ActiveRecord::Base.connection_pool.with_connection do
      process
    end
  rescue => e
    # 记录异常日志，按需处理
    Rails.logger.error "Task failed: #{e.message}\n#{e.backtrace.join("\n")}"
  end
end

即使process抛出异常，with_connection的ensure块仍会执行，避免连接被遗留。

2. 配置线程池的异常处理策略 #

通过concurrent-ruby的钩子和配置，避免线程因未捕获异常死亡：

pool = Concurrent::ThreadPoolExecutor.new(
  min_threads: 5,
  max_threads: 10,
  fallback_policy: :abort
)

# 全局捕获线程池任务的异常
Concurrent.global_io_executor.on(:task_completed) do |task|
  if task.failed?
    Rails.logger.error "Task failed: #{task.error.message}\n#{task.error.backtrace.join("\n")}"
  end
end

3. 清理已死亡线程的连接 #

定期检查并释放连接池中归属已死亡线程的连接（注意：此方式属于内部API操作，升级Rails时需验证兼容性）：

def cleanup_dead_thread_connections
  ActiveRecord::Base.connection_pool.instance_eval do
    @connections.each do |conn|
      release(conn) if conn.owner && !conn.owner.alive?
    end
  end
end

# 提交任务前执行清理
cleanup_dead_thread_connections
pool.post do
  ActiveRecord::Base.connection_pool.with_connection do
    process
  end
end

4. 改用Rails内置线程池（可选） #

如果业务场景允许，使用Rails内置的ActiveJob或连接池工具，它们已针对ActiveRecord的连接管理做了优化，能避免线程-连接归属冲突问题。

内容的提问来源于stack exchange，提问作者testing09