new_worker()はBackgrounDRb側のプロセスで実行される。 ぱっと見る限り、スレッドが並列して動くように見える。 各ワーカはスレッドセーフになるように気をつける必要があるのかな？ def new_worker(opts={}) @mutex.synchronize { job_key = opts[:job_key…

"10000000".scan(/(\d+?)(?=\d{3}*$)/).join(",") #=> "10,000,000"