TudbuT/tuddylib
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

make consecutive lock calls not break timing
All checks were successful
/ Build & Publish (push) Successful in 53s
Details

Browse source
This commit is contained in:
Daniella 2024-06-25 05:05:55 +02:00
parent bee64f9ee1
commit 1f301d292e
Signed by: TudbuT
GPG key ID: B3CF345217F202D3
1 changed files with 24 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
src/main/java/de/tudbut/tools/Lock.java
View file

@ -7,6 +7,7 @@ public class Lock extends SimpleLock {
private boolean isTimed = false;
private long startTime = 0, lockTime = 0;
private boolean relocking = false;
/**
* Creates a Lock without default state
@ -62,12 +63,14 @@ public class Lock extends SimpleLock {
if(!super.isLocked())
return;
long wt = timeLeft0();
if(wt == 0) {
unlock();
return;
while(relocking) {
long wt = timeLeft0();
if(wt == 0) {
unlock();
return;
}
super.waitHere(wt);
}
super.waitHere(wt);
}
/**
@ -84,18 +87,23 @@ public class Lock extends SimpleLock {
if(!super.isLocked())
return;
long wt = timeLeft0();
if(wt == 0) {
unlock();
return;
long start = System.currentTimeMillis();
while(relocking) {
long wt = timeLeft0();
if(wt == 0) {
unlock();
return;
}
long sectionOffset = System.currentTimeMillis() - start;
super.waitHere(Math.min(wt, timeout - sectionOffset));
}
super.waitHere(Math.min(wt, timeout));
}
/**
* Unlock manually
*/
public synchronized void unlock() {
relocking = false;
super.unlock();
startTime = 0;
lockTime = 0;
@ -105,9 +113,12 @@ public class Lock extends SimpleLock {
* Lock until manually unlocked
*/
public synchronized void lock() {
relocking = super.isLocked();
startTime = System.currentTimeMillis();
isTimed = false;
super.lock();
if(relocking)
notifyAll();
}
/**
@ -118,10 +129,13 @@ public class Lock extends SimpleLock {
if(time == 0)
return;
relocking = super.isLocked();
startTime = System.currentTimeMillis();
lockTime = time;
isTimed = true;
super.lock();
if(relocking)
notifyAll();
}
/**