BLOGTIMES
2019/11/06

mysql2 をスレッドセーフに

  ruby 
このエントリーをはてなブックマークに追加

gem mysql2 をマルチスレッドで使っていたら、以下のようなエラーがでて困ってしまいました。

This connection is in use by: #<Thread:0x000000020e0c70 sleep> (Mysql2::Error)

どうやら mysql2 はスレッドセーフではないことが原因の模様。

いろいろと調べてみたら、MutexLockedQuerying*1というモジュールを書いている人を見つけたので、ちょっと改造して取り込んでみました。元の実装だとクラス変数を使っているのでロックがインスタンス単位ではなく、グローバルにかかってしまうので、インスタンス変数に変更してあります。ロックの粒度的にはこちらの方が望ましいはずです。

require 'mysql2' module MutexLockedQuerying def initialize(*) @semaphore = Mutex.new super end def query(*) @semaphore.synchronize { super } end end Mysql2::Client.send(:prepend, MutexLockedQuerying)

トラックバックについて
Trackback URL:
お気軽にどうぞ。トラックバック前にポリシーをお読みください。[policy]
このエントリへのTrackbackにはこのURLが必要です→https://blog.cles.jp/item/11326
Trackbacks
このエントリにトラックバックはありません
Comments
愛のあるツッコミをお気軽にどうぞ。[policy]
古いエントリについてはコメント制御しているため、即時に反映されないことがあります。
コメントはありません
Comments Form

OpenID を使ってログインすることができます。

Identity URL: Yahoo! JAPAN IDでログイン