如何在Mutex.synchronize中获取局部变量值？

Question

我正在努力使代码多线程，以便更快地进行数据分析。为了避免多线程数据库连接问题，我使用Mutex来锁定它。

lock = Mutex.new()
thread_num.times do |i|
    threads << Thread.new do
        lock.synchronize{
             records = db_proxy.query(account_id) 
             result = process_records(records) 
        }        
    end
end

process_records也很耗时，但作为常规方法，它支持多线程调用。它需要来自mdb_proxy.query的输出，如何从process_records中取出lock.synchronize，同时让它等待来自mdb_proxy.query的结果，我尝试了以下但是得到了局部变量异常

lock = Mutex.new()
    thread_num.times do |i|
        threads << Thread.new do
            lock.synchronize{
                 records = mdb_proxy.query(account_id) 
            }   
            result = process_records(records) 
        end
    end

Answer 1

将记录分配给哪个块返回：

records = lock.synchronize { mdb_proxy.query(account_id) }