Redisson 分散ロック ソースコード フェアロック リリース

[[408803]]

序文

ウォッチドッグ メカニズムは、RedissonBaseLock#scheduleExpirationRenewal メソッドにあります。このフェアロックとアンフェアロックの間には違いはありません。

前に学んだように、公平なロックが失敗すると、現在のロックは待機キューに配置され、Java コードのループを通じてロックの取得が試行されます。

1. ロック解除

アクティブリリース

ソースコード: RedissonFairLock#unlockInnerAsync

• KEYS[1]: ロック名、anyLock;
• KEYS[2]: ロック待機キュー、redisson_lock_queue:{anyLock};
• KEYS[3]: 待機キュー内のスレッドロック時間のセット、redisson_lock_timeout:{anyLock}。ロックタイムスタンプに従ってセットに格納されます。
• キー[4]:redisson_lock__channel:{anyLock};
• ARGV[1]：LockPubSub.UNLOCK_MESSAGE;
• ARGV[2]: ロックタイムアウト30000;
• ARGV[3]: UUID:スレッドIDの組み合わせ58f6c4a2-9908-4957-b229-283a45359c4b:47;
• ARGV[4]: currentTime 現在のタイムスタンプ。

このロジックのハイライト部分はマークされており、重要なポイントはロックを解除することです。

1. キューにロックされ、タイムアウトの場合はキューから直接削除されます。
2. ロックにより再入回数が減ります。削減後、再入回数が 0 より大きい場合は、タイムアウトがリセットされます。 0 より大きくない場合は、ロックは直接削除されます。

このようにして、他のスレッドは待機キューからロックを取得し始めます。

タイムアウト削除

ロックのロックと解放を行う Lua スクリプトでは、最初の段落は常に while true do xxx であり、キュー内のタイムアウトしたロックを削除するために使用されます。

ロックを保持しているスレッドの解放は、不正なロックと変わりません。ロックがタイムアウトするか、サービスが停止すると、ロックは自動的に解除されます。 (これは anyLock を指します)。

2. まとめ

フェアロックの解放もアクティブ解放とタイムアウト解放に分けられます。

アクティブリリース、つまりリリースロックを自分で呼び出します。

タイムアウト削除には 2 種類あります。 1 つは、ロックを保持しているスレッドのタイムアウト削除です。このロックにもタイムアウト期間 + ウォッチドッグの更新が含まれているため、これは不公平なロックと変わりません。もう 1 つは、キュー内でタイムアウト削除を待機することです。毎回ロックを取得する前に、最初の待機スレッドのタイムスタンプがタイムアウトしたかどうかを判断し、ロックを解除する必要があります。

この記事はWeChatの公開アカウント「Programmer Xiaohang」から転載したもので、以下のQRコードからフォローできます。この記事を転載する場合は、プログラマーXiaohangの公式アカウントまでご連絡ください。