How to build a exclusive Lock


ブロックlockの基本フロー
if(cas(0,acquire))
setExclusiveOwnerThread
else if(current==getExclusiveOnwerThread) {
     setState(c+acquires)
}
addWaiter
park
........................
for(;;) {
p = node.predecessor
if(p==head&&tryAcquire(arg)){
setHead(node)
return
}
park
}
 
releaseの基本フローをブロック
if(current!=getExclusiveOnwerThread){
IllegalMonitorStateException
}
if(c == 0){
setExclusive(null)
free = true
}
setState(c)
return free
unparkSuccessor(LockSupport.unpark(thread))
 
非ブロックlockの基本フロー
if(cas(0,acquire)) 
     setExclusiveOwnerThread   true
else if(current==getExclusiveOwnerThread)
     setState(c+acquire)    true
false
 
非ブロックreleaseの基本フロー
ブロックされたreleaseプロセスと同じ
 
 
共有lockの基本フローをブロック
tryAcquireShared(acquires){
for(;;) {
remaining = state-acquires
if(remaining<0 || CAS(state,remaining))
return remaining
}
}
 
 
if(tryAcquireShared(arg)<0){
     node = addWaiter(Node.SHARED)
     for(;;) {
p = node.predecessor
propagate = tryAcquireShared(arg)
if(p==head&&propagate>=0){
setHead(node)
if(propagate>0||next==null||next.isShared()/残りがある場合は、次のノードを起動し続けます
     doReleaseShared() 
return
}
park
     }
}
 
共有releaseの基本フローをブロック
tryReleaseShared(acquires){
for(;;){
     if(cas(state,state+acquires)) 
          return true
}
 
}
if(tryReleaseShared(acquires)) {
     unparkSuccessor(h)
}
 
 
 
 
 
共有lockの基本モード
tryAcquireSharedメソッドの上書き
for(;;) {
     if(state-acquire<0) {
          false
     }
     if(cas(state,state-acquires)) {
          true
     }
}
 
ロックを共有するreleaseの基本モード
tryReleaseSharedメソッドの上書き
for(;;) {
     if(cas(state,state+acquires)) {
          true
     }
}
 
排他lockの基本モード
tryAcquireメソッドの上書き
if(state==0) {
     if(cas(state, state+acquire)) {
          setExclusiveOwnerThread(current)
              return true
     }
} else if(current==getExclusiveOwnerThread) {
     if(cas(state, state+acquire)) {
          return true
     }
}
return flase

ロックのrelease基本モードを並べます
tryReleaseメソッドの上書き
if(current != getExclusiveThread) {
     throw new IllegalMonitorStateException()
}
nextc = state-release
if(nextc == 0) {
     setState(nextc)
     setExclusiveOwnerThread(current)
     return true
} else {
     setState(nextc)
     return false
}