- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of about 10,000 for acquired (0.17 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockCoordinationService.java
* that tells the resource coordinator how to proceed: * * FINISHED - All locks were acquired, release the state lock * FAILED - One or more locks were not acquired, roll back any locks that were acquired and release the state lock * RETRY - One or more locks were not acquired, roll back any locks that were acquired and block waiting for the * state to change, then run the transform again *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/ConditionalExecutionQueue.java
*/ package org.gradle.internal.work; import org.gradle.internal.concurrent.Stoppable; /** * Represents a queue of executions that can run when a provided resource lock can be acquired. The typical use case would * be that a worker lease must be acquired before execution. */ public interface ConditionalExecutionQueue<T> extends Stoppable { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.5K bytes - Viewed (0) -
src/runtime/mklockrank.go
// the syntax. // // "a < b" means a must be acquired before b if both are held // (or, if b is held, a cannot be acquired). // // "NONE < a" means no locks may be held when a is acquired. // // If a lock is not given a rank, then it is assumed to be a leaf // lock, which means no other lock can be acquired while it is held. // Therefore, leaf locks do not need to be given an explicit rank. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy
when: async { start { cacheAccess.withFileLock { instant.acquired thread.blockUntil.closed } } start { thread.blockUntil.acquired try { cacheAccess.close() } finally { instant.closed
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 21.8K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/filelock/FileLockOutcome.java
}; public boolean isLockWasAcquired() { return false; } public FileLock getFileLock() { throw new IllegalStateException("Lock was not acquired"); } static FileLockOutcome acquired(FileLock fileLock) { return new FileLockOutcome() { @Override public boolean isLockWasAcquired() { return true; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/Synchronizer.java
* * Fails if the current thread is already holding the resource lock. May release project locks prior to blocking, as per {@link WorkerLeaseService#blocking(Runnable)}. */ void withLock(Runnable action); /** * Runs the given action while holding the associated resource lock, blocking until the lock can be acquired. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* * <p>Deadlocks can arise when locks are acquired in an order that forms a cycle. In a simple * example involving two locks and two threads, deadlock occurs when one thread acquires Lock A, and * then Lock B, while another thread acquires Lock B, and then Lock A: * * <pre> * Thread1: acquire(LockA) --X acquire(LockB) * Thread2: acquire(LockB) --X acquire(LockA) * </pre> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy
coordinationService.withStateLock(lock(sharedResourceLock)) assert lockIsHeld(sharedResourceLock) acquired.countDown() acquired.await() coordinationService.withStateLock(unlock(sharedResourceLock)) } } } then: noExceptionThrown() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
type Weighted struct { size int64 cur int64 mu sync.Mutex waiters list.List } // Acquire acquires the semaphore with a weight of n, blocking until resources // are available or ctx is done. On success, returns nil. On failure, returns // ctx.Err() and leaves the semaphore unchanged. func (s *Weighted) Acquire(ctx context.Context, n int64) error { done := ctx.Done() s.mu.Lock() select { case <-done:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileLockManager.java
@ServiceScope(Scope.Global.class) public interface FileLockManager { /** * Creates a lock for the given file with the given mode. Acquires a lock with the given mode, which is held until the lock is * released by calling {@link FileLock#close()}. This method blocks until the lock can be acquired. * * @param target The file to be locked. * @param options The lock options.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.1K bytes - Viewed (0)