- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for operationComplete (0.18 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
grm.operations = grm.operations[:len(grm.operations)-1] } func (grm *nestedPendingOperations) operationComplete(key operationKey, err *error) { // Defer operations are executed in Last-In is First-Out order. In this case // the lock is acquired first when operationCompletes begins, and is // released when the method finishes, after the lock is released cond is // signaled to wake waiting goroutine.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
private final ReentrantLock lock = new ReentrantLock(); private final Condition workAvailable = lock.newCondition(); private final Condition operationsComplete = lock.newCondition(); private QueueState queueState = QueueState.Working; private int workerCount; private int pendingOperations; private final Deque<T> workQueue = new LinkedList<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0)