- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for newWorkerLease (0.16 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
def projectLock = workerLeaseService.getProjectLock(path("root"), path(":project")) when: async { start { def workerLease = workerLeaseService.newWorkerLease() workerLeaseService.withLocks([projectLock, workerLease]) { workerLeaseService.runAsIsolatedTask { thread.blockUntil.projectLocked }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseRegistry.java
* {@link ResourceLock#tryLock()} is called from a {@link org.gradle.internal.resources.ResourceLockCoordinationService#withStateLock(org.gradle.api.Transformer)} * transform. */ WorkerLease newWorkerLease(); interface WorkerLease extends ResourceLock { } interface WorkerLeaseCompletion { /** * Marks the completion of a worker lease, releasing the lease. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceWorkerLeaseTest.groovy
cleanup: registry?.stop() } def "can use worker lease as resource lock"() { def registry = workerLeaseService(1) when: def workerLease = registry.newWorkerLease() coordinationService.withStateLock(lock(workerLease)) then: noExceptionThrown() } def "acquire lease as resource lock blocks when there are no leases available"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 13.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
throw new IllegalStateException("Expected the current thread to hold a single worker lease"); } return operations.get(0); } @Override public DefaultWorkerLease newWorkerLease() { return workerLeaseLockRegistry.newResourceLock(); } @Override public boolean isWorkerThread() { return workerLeaseLockRegistry.holdsLock(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/work/TestWorkerLeaseService.groovy
runnable.run() } @Override <T> T runAsIsolatedTask(Factory<T> action) { return action.create() } @Override WorkerLease newWorkerLease() { return workerLease() } @Override <T> T withLocks(Collection<? extends ResourceLock> locks, Factory<T> factory) { return factory.create() } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0)