Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2024-06-28 23:44:58 +02:00
Code Issues Projects Releases Wiki Activity

Simplify Acquirable#lock

Browse Source
This commit is contained in:
TheMode 2021-04-25 23:07:31 +02:00
parent 6c3c6e1438
commit b8b62c4ff7
2 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/net/minestom/server/acquirable/Acquirable.java
View File

@ -83,13 +83,7 @@ public interface Acquirable<T> {
*/
default @NotNull Acquired<T> lock() {
var optional = local();
if (optional.isPresent()) {
return Acquired.local(optional.get());
} else {
final Thread currentThread = Thread.currentThread();
final TickThread tickThread = getHandler().getTickThread();
return Acquired.locked(unwrap(), currentThread, tickThread);
}
return optional.map(Acquired::local).orElseGet(() -> Acquired.locked(this));
}
/**

6
src/main/java/net/minestom/server/acquirable/Acquired.java
View File

@ -19,8 +19,10 @@ public class Acquired<T> {
return new Acquired<>(value, false, null, null);
}
protected static <T> Acquired<T> locked(@NotNull T value, Thread currentThread, TickThread tickThread) {
return new Acquired<>(value, true, currentThread, tickThread);
protected static <T> Acquired<T> locked(@NotNull Acquirable<T> acquirable) {
final Thread currentThread = Thread.currentThread();
final TickThread tickThread = acquirable.getHandler().getTickThread();
return new Acquired<>(acquirable.unwrap(), true, currentThread, tickThread);
}
private Acquired(@NotNull T value,