Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for newWorkerLease (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java

            @Override
            public void run() {
                try {
                    boolean releaseLeaseOnCompletion;
                    if (workerLease == null) {
                        workerLease = workerLeaseService.newWorkerLease();
                        releaseLeaseOnCompletion = true;
                    } else {
                        releaseLeaseOnCompletion = false;
                    }
    
                    while (true) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 29.1K bytes
    - Viewed (0)
Back to top