1berry/openjdk
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

8336384: AbstractQueuedSynchronizer.acquire should cancel acquire when failing due to a LinkageError or other errors

Browse Source 
Reviewed-by: alanb
This commit is contained in:
Viktor Klang 2024-08-13 09:51:08 +00:00
parent ba69ed7c58
commit fbe4cc96e2
2 changed files with 24 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/java.base/share/classes/java/util/concurrent/locks/AbstractQueuedLongSynchronizer.java
View File

@ -369,14 +369,19 @@ public abstract class AbstractQueuedLongSynchronizer
} else if (node.status == 0) { } else if (node.status == 0) {
node.status = WAITING; // enable signal and recheck node.status = WAITING; // enable signal and recheck
} else { } else {
long nanos;
spins = postSpins = (byte)((postSpins << 1) | 1); spins = postSpins = (byte)((postSpins << 1) | 1);
try {
long nanos;
if (!timed) if (!timed)
LockSupport.park(this); LockSupport.park(this);
else if ((nanos = time - System.nanoTime()) > 0L) else if ((nanos = time - System.nanoTime()) > 0L)
LockSupport.parkNanos(this, nanos); LockSupport.parkNanos(this, nanos);
else else
break; break;
} catch (Error | RuntimeException ex) {
cancelAcquire(node, interrupted, interruptible); // cancel & rethrow
throw ex;
}
node.clearStatus(); node.clearStatus();
if ((interrupted |= Thread.interrupted()) && interruptible) if ((interrupted |= Thread.interrupted()) && interruptible)
break; break;

7
src/java.base/share/classes/java/util/concurrent/locks/AbstractQueuedSynchronizer.java
View File

@ -748,14 +748,19 @@ public abstract class AbstractQueuedSynchronizer
} else if (node.status == 0) { } else if (node.status == 0) {
node.status = WAITING; // enable signal and recheck node.status = WAITING; // enable signal and recheck
} else { } else {
long nanos;
spins = postSpins = (byte)((postSpins << 1) | 1); spins = postSpins = (byte)((postSpins << 1) | 1);
try {
long nanos;
if (!timed) if (!timed)
LockSupport.park(this); LockSupport.park(this);
else if ((nanos = time - System.nanoTime()) > 0L) else if ((nanos = time - System.nanoTime()) > 0L)
LockSupport.parkNanos(this, nanos); LockSupport.parkNanos(this, nanos);
else else
break; break;
} catch (Error | RuntimeException ex) {
cancelAcquire(node, interrupted, interruptible); // cancel & rethrow
throw ex;
}
node.clearStatus(); node.clearStatus();
if ((interrupted |= Thread.interrupted()) && interruptible) if ((interrupted |= Thread.interrupted()) && interruptible)
break; break;