Clarify thread-safety guarantees

trinodb · Aug 26, 2024 · 8347f3c · 8347f3c
1 parent 1d5510c
commit 8347f3c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/core/trino-main/src/main/java/io/trino/execution/executor/scheduler/Reservation.java b/core/trino-main/src/main/java/io/trino/execution/executor/scheduler/Reservation.java
@@ -15,6 +15,7 @@
 
 import com.google.common.collect.ImmutableSet;
 import com.google.errorprone.annotations.ThreadSafe;
+import com.google.errorprone.annotations.concurrent.GuardedBy;
 
 import java.util.HashSet;
 import java.util.Set;
@@ -35,6 +36,8 @@
 final class Reservation<T>
 {
     private final Semaphore semaphore;
+
+    @GuardedBy("this")
     private final Set<T> reservations = new HashSet<>();
     private final int slots;