ロックとトランザクションの検証

検証結果

lockしたレコードはtransactionがcommitされるまでロックされ続ける。

実行結果

| コンソール1 | コンソール2 | |—————————–|————————–| | 検索前: 03:01:03.185, 100 | ↓ | | 検索後: 03:01:03.188, 100 | ↓ | | ロック前: 03:01:03.189, 100 | ↓ | | ロック後: 03:01:03.193, 100 | ↓ | | スリープ前: 03:01:03.194, 100 | ↓ | | ↓ | 検索前: 03:01:04.203, 100 | | ↓ | 検索後: 03:01:04.208, 100 | | ↓ | ロック前: 03:01:04.210, 100 | | スリープ後: 03:01:08.201, 100 | ↓ | | 更新前: 03:01:08.207, 100 | ↓ | | 更新後: 03:01:08.216, 0 | ↓ | | スリープ前: 03:01:08.218, 0 | ↓ | | スリープ後: 03:01:13.197, 0 | ↓ | | ロールバック前: 03:01:13.203, 0 | ↓ | | ↓ | ロック後: 03:01:13.210, 100 | | ↓ | 更新前: 03:01:13.213, 100 | | ロールバック後: 03:01:13.219, 100 | ↓ | | | 更新後: 03:01:13.220, 50 |

検証に用いたコード

コンソール１で実行(first_execution)

def now; Time.now.strftime("%H:%M:%S.%L"); end def tagging(action, timeline) timeline << "#{action}前: #{now}, #{point}" value = yield timeline << "#{action}後: #{now}, #{point}" return value end def point UserPoint.find(1).point end def first_execution timeline = [] rup = UserPoint.find(1) rup.assign_attributes(point: 100) rup.save! begin ApplicationRecord.transaction do user_point = tagging("検索", timeline, &-> () { UserPoint.find(1) }) tagging("ロック", timeline, &-> () { user_point.lock! }) tagging("スリープ", timeline, &-> () { sleep 5 }) user_point.point = user_point.point - 100 tagging("更新", timeline, &-> () { user_point.save! }) tagging("スリープ", timeline, &-> () { sleep 5 }) tagging("ロールバック", timeline, &-> () { raise ActiveRecord::Rollback }) end ensure timeline << "ロールバック後: #{now}, #{point}" puts timeline end end

コンソール２で実行(second_execution)

def now; Time.now.strftime("%H:%M:%S.%L"); end def tagging(action, timeline) timeline << "#{action}前: #{now}, #{point}" value = yield timeline << "#{action}後: #{now}, #{point}" return value end def point UserPoint.find(1).point end def second_execution timeline = [] begin ApplicationRecord.transaction do user_point = tagging("検索", timeline, &-> () { UserPoint.find(1) }) tagging("ロック", timeline, &-> () { user_point.lock! }) user_point.point = user_point.point - 50 tagging("更新", timeline, &-> () { user_point.save! }) end ensure puts timeline end end