ZooKeeper 分散ロック キュレーター ソース コード 2: 再入可能ロックの繰り返しロックとロック解除

[[410320]]

序文

ロックロジックが導入されました。では、スレッドの繰り返しロックにはどのように対処すればよいのでしょうか?

1. 再入室をロックする

前のセクションでは、ロックのプロセスを確認し、次に internalLock メソッドをもう一度見てみましょう。

ロックが正常に取得されると、現在のスレッドはConcurrentMapであるthreadDataに配置されます。

ロックが再入力された場合は、前の部分 lockData != null で直接停止し、lockData.lockCount.incrementAndGet(); を実行します。

lockCount の増加はロックの再入力を示します。

ここに注意してください！ Curator のロック再入機能は Java コードで実装されています。

2. ロック解除

ロックを解除する必要がある場合は、lock.release() を呼び出して解除するだけです。具体的にはどのようにリリースされるのでしょうか?

主に 2 つの部分に分かれています。

1. threadData 内の現在のスレッドのロックの数を減らします。
2. ロックの数が 0 より大きい場合は、まだ再入時間が残っていることを意味するので、直接戻ります。
3. ロックの数が 0 の場合、releaseLock はロックを解除し、threadData 内の現在のスレッド キーを削除します。

releaseLock メソッドには、リスナーを削除して一時シーケンス ノードを削除するという複雑なロジックはあまりありません。つまり、/locks/lock_01/_c_e855d232-c636-4241-bf8e-f047939a5833-lock-0000000001 です。

3. まとめ

ZooKeeper の InterProcessMutex ロックは、Java コード内の lockCount を維持し、再入可能かどうかを判断します。

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