如何并行执行ActiveRecord查询？大数据量表能否同时执行Article.all与Tomato.all？

当然可以并行执行ActiveRecord查询！当你面对Article和Tomato这类数据量庞大的表时，完全可以通过一些手段同时触发这两个查询操作，不过得留意几个关键细节，避免踩坑。

一、用Ruby原生线程实现并行查询 #

最直接的方式就是借助Ruby的Thread类，让两个查询在不同线程里同时执行，示例代码如下：

# 启动两个线程分别执行查询
articles_thread = Thread.new { Article.all }
tomatoes_thread = Thread.new { Tomato.all }

# 等待线程执行完毕，获取结果
articles = articles_thread.value
tomatoes = tomatoes_thread.value

原理很简单：两个线程会各自向数据库发起查询请求，不用等第一个查询结束再启动第二个，能有效节省总耗时。

二、关键注意事项 #

1. 数据库连接池配置 #

每个线程都需要独立的数据库连接，所以一定要确保config/database.yml里的pool参数设置足够大。比如你要跑2个并行查询，pool值至少要≥2，不然线程会因为等待可用连接而阻塞，反而失去并行的意义。

2. 大表数据的内存问题 #

如果Article.all和Tomato.all会把几十万甚至上百万条记录一次性加载到内存里，很容易导致内存溢出（OOM）。这种情况下，建议改用分批加载的方式，比如用find_each：

# 分批加载数据，避免内存暴涨
articles_thread = Thread.new do
  articles = []
  Article.find_each(batch_size: 1000) do |article|
    articles << article
    # 或者在这里直接处理单条数据，不用存到数组里
  end
  articles
end

tomatoes_thread = Thread.new do
  tomatoes = []
  Tomato.find_each(batch_size: 1000) do |tomato|
    tomatoes << tomato
  end
  tomatoes
end

如果你的业务不需要把所有数据都存在内存里，直接在find_each的块里处理单条数据会更高效。

3. 线程安全与事务 #

ActiveRecord的数据库连接是线程本地的，所以每个线程的查询是完全独立的，不用担心连接冲突。但要注意：不要跨线程操作同一个事务，事务是绑定在当前线程的连接上的，跨线程操作会导致不可预期的问题。

三、其他可选方案 #

如果需要更复杂的并发控制，也可以用concurrent-ruby这类第三方库的Future来实现，但对于这种简单的并行查询场景，Ruby原生线程已经足够好用，没必要额外引入依赖。

总的来说，并行执行ActiveRecord查询是完全可行的，但一定要结合数据量大小调整数据加载方式，同时配置好数据库连接池，避免资源耗尽。

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