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

デフォルトのロックロジックは不公平です。

ロックが失敗すると、スレッドは while ループに入り、ロックの取得を試行し続けます。このとき、複数のスレッドが競合することになります。つまり、最初にそれを獲得した人がそれを所有することになります。

Redisson は、次のように使用できる公平なロックメカニズムを提供します。

 RLock fairLock = redisson.getFairLock( "anyLock" );
 // 最も一般的な使用法
ロックをロックします。

公平ロックがどのように実装されるかを見てみましょう。

これまでの記事を読んだ後は、すでにこのメソッドに精通しており、ソースコードメソッド RedissonFairLock#tryLockInnerAsync を直接見つけることができると思います。

わあ、これは膨大なコードなので、スクリーンショットですべてをキャプチャすることはできません。そのため、Lua スクリプトを直接分析してみましょう。

PS: Lua は理解できませんが、これらの if else の山はおそらく理解できるでしょう。

デバッグで command == RedisCommands.EVAL_LONG が見つかったため、次の部分を直接確認します。

長すぎて「いい人」って何回も言ってしまいました！

まずパラメータが何であるかを見てみましょう。

KEYS[1]: ロック名、anyLock;
KEYS[2]: ロック待機キュー、redisson_lock_queue:{anyLock};
KEYS[3]: 待機キュー内のスレッドロック時間のセット、redisson_lock_timeout:{anyLock}。ロックタイムスタンプに従ってセットに格納されます。
ARGV[1]: ロックタイムアウト30000;
ARGV[2]: UUID:スレッドIDの組み合わせa3da2c83-b084-425c-a70f-5d9a08b37f31:1;
ARGV[3]: threadWaitTimeのデフォルトは300000です。
ARGV[4]: currentTime 現在のタイムスタンプ。

ロックキューとセットは中括弧で囲まれた文字列です。 {XXXX} は、このキーがスロット位置を計算するために XXXX のみを使用することを意味します。

上記の Lua スクリプトはいくつかの部分に分かれています。上記のコードの実行をさまざまな角度から見てみましょう。

最初のロック（スレッド1）

最初の部分では、ロックするのは初めてなので、待機キューは空であり、ループは直接飛び出します。実行のこの部分は終了しました。

パート II:

ここで実行したら戻ります。なので、今のところ以降の部分は読みません。

次の 2 つのコマンドと同等です (Lua スクリプト全体がアトミックです)。

 > hset anyLock a3da2c83-b084-425c-a70f-5d9a08b37f31:1 1
 > pexpire anyLock 30000

スレッド2ロック

Thread1 がロックを完了すると、Thread2 がロックを開始します。

Thread2 は、このインスタンスの別のスレッド、または別のインスタンスのスレッドにすることができます。

最初の部分では、ロックは Thread1 によって占有されていますが、待機キューは空なので、ループは直接飛び出します。

2 番目の部分では、ロックが存在するので、スキップします。

3 番目の部分は、スレッドがロックを保持しているかどうかです。そうでない場合は、直接スキップしてください。

4 番目の部分は、スレッドが待機キューにあるかどうかです。Thread2 はそれをロックし、そうでない場合は直接スキップされます。

スレッド2はここで終了します:

zadd KEYS[3] タイムアウトARGV[2]

ここでは、zadd コマンドを使用して、redisson_lock_timeout:{anyLock}、タイムアウトタイムスタンプ (1624612689520)、およびスレッド (UUID2:Thread2) を配置します。

タイムアウトタイムスタンプは、順序付けられたセット内でソートするためのスコアとして使用され、ロックの順序を示します。

スレッド3ロック

スレッド 1 がロックを保持し、スレッド 2 が待機し、その後スレッド 3 が来ます。

firstThreadId2を取得します。この時点で、キューには UUID2:Thread2 のスレッドがあります。

firstThreadId2 のスコア (タイムアウトタイムスタンプ) が現在のタイムスタンプより小さいかどうかを判断します。

タイムアウト以下の場合は、firstThreadId2 を削除します。

より大きい場合は、その後の判定に入ります。

2番目、3番目、4番目の部分は要件を満たしていません。

Thread3 もここで終了します:

スレッド待機キューから最後のスレッドを取得します redisson_lock_queue:{anyLock};
最後のスレッドが存在し、それがそれ自身ではない場合は、ttl = lastThreadId タイムアウトタイムスタンプ - 現在のタイムスタンプとなり、最後のスレッドがタイムアウトするまでの時間を確認します。
アセンブリタイムアウト時間 = ttl + 300000 + 現在のタイムスタンプ。 300000 は 60000*5 のデフォルト値です。最後のスレッドのタイムアウト（Thread3 のタイムアウトタイムスタンプ）に 300000 と現在のタイムスタンプを追加します。
zadd を使用して Thread3 を待機スレッド順序セットに追加し、rpush を使用して Thread3 を待機キューに戻します。