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メソッドの上書き
ロックを共有するreleaseの基本モード
tryReleaseSharedメソッドの上書き
排他lockの基本モード
tryAcquireメソッドの上書き
ロックのrelease基本モードを並べます
tryReleaseメソッドの上書き
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
}