如何制作ActiveRecord ThreadSafe

如何使用postgresql在rails 4中创建以下控制器线程安全：

def controller_action if Model.exists(column_name:"some_value") else @model=Model.new(column_name:"some_value") @model.save end end 

我正在运行puma，所以我担心的是，如果两个线程同时运行此控制器，并且不存在具有指定值column_name的行，则将创建两个记录，而我只想要1。

Answer 1

与注释相反，同一个表上的并发插入在PostgreSQL中是完全允许的，因此这里存在竞争条件。

要使此安全，您必须在column_name上具有unique约束（或primary key ）。 然后，重复插入将抛出一个exception，您可以捕获并重试更新。

如果您没有唯一约束，则必须LOCK TABLE ... IN EXCLUSIVE MODE以防止并发upsert。 或者使用以下描述的并发安全方法之一：

如何在PostgreSQL中UPSERT（MERGE，INSERT …在DUPLICATE UPDATE上）？

Answer 2

假设线程与连接具有1：1的关系。 因此，如果您有100个需要访问数据库的线程，则应该将连接池调高到100个。如果您有多个工作线程而不是连接，则需要使用Queue（或其他一些线程安全数据结构）来管理通信它们之间。