Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for acquireLock (0.37 sec)

  1. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/AbstractTrackedResourceLock.java

        public String toString() {
            return getClass().getSimpleName() + " " + getDisplayName();
        }
    
        @Override
        public boolean tryLock() {
            if (!isLockedByCurrentThread()) {
                if (acquireLock()) {
                    LOGGER.debug("{}: acquired lock on {}", Thread.currentThread().getName(), displayName);
                    try {
                        owner.lockAcquired(this);
                    } catch (RuntimeException e) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  2. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultLease.java

            return ownerThread != null;
        }
    
        @Override
        protected boolean doIsLockedByCurrentThread() {
            return Thread.currentThread() == ownerThread;
        }
    
        @Override
        protected boolean acquireLock() {
            if (parent.grantLease()) {
                ownerThread = Thread.currentThread();
            }
            return ownerThread != null;
        }
    
        @Override
        protected void releaseLock() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  3. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ExclusiveAccessResourceLock.java

            super(displayName, coordinationService, owner);
        }
    
        @Override
        protected boolean acquireLock() {
            Thread currentThread = Thread.currentThread();
            if (owner == currentThread) {
                return true;
            }
            if (owner == null && canAcquire()) {
                owner = currentThread;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  4. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/TestTrackedResourceLock.groovy

            return lockedState.get()
        }
    
        @Override
        boolean doIsLockedByCurrentThread() {
            return owner.get() == Thread.currentThread()
        }
    
        @Override
        protected boolean acquireLock() {
            if (!lockedState.get()) {
                owner.set(Thread.currentThread())
                lockedState.set(true)
                return true
            } else {
                return false
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. subprojects/core/src/main/java/org/gradle/internal/model/CalculatedValueContainer.java

                this.defaultContext = defaultContext;
            }
    
            // Can be called multiple times
            void attachValue(CalculatedValueContainer<T, ?> owner, @Nullable NodeExecutionContext context) {
                acquireLock();
                try {
                    if (done) {
                        // Already calculated
                        return;
                    }
                    done = true;
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 18 08:26:19 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          for (LockGraphNode acquiredLock : acquiredLocks) {
            checkAcquiredLock(policy, acquiredLock);
          }
        }
    
        /**
         * Checks the acquisition-ordering between {@code this}, which is about to be acquired, and the
         * specified {@code acquiredLock}.
         *
         * <p>When this method returns, the {@code acquiredLock} should be in either the {@code
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          for (LockGraphNode acquiredLock : acquiredLocks) {
            checkAcquiredLock(policy, acquiredLock);
          }
        }
    
        /**
         * Checks the acquisition-ordering between {@code this}, which is about to be acquired, and the
         * specified {@code acquiredLock}.
         *
         * <p>When this method returns, the {@code acquiredLock} should be in either the {@code
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  8. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java

            return unlock(Arrays.asList(resourceLocks));
        }
    
        private static class AcquireLocks implements InternalTransformer<ResourceLockState.Disposition, ResourceLockState> {
            private final Iterable<? extends ResourceLock> resourceLocks;
            private final boolean blocking;
    
            AcquireLocks(Iterable<? extends ResourceLock> resourceLocks, boolean blocking) {
                this.resourceLocks = resourceLocks;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 17:16:10 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  9. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java

            }
        }
    
        private void releaseLocks(Iterable<? extends ResourceLock> locks) {
            coordinationService.withStateLock(unlock(locks));
        }
    
        private void acquireLocks(final Iterable<? extends ResourceLock> locks) {
            if (containsProjectLocks(locks)) {
                projectLockStatistics.measure(new Runnable() {
                    @Override
                    public void run() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 09 04:43:28 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. test-site/activator-launch-1.3.2.jar

    private long timeout; private java.util.Map currentLockCounters; protected void FileBasedLockStrateg(); protected void FileBasedLockStrateg(boolean); private void FileBasedLockStrateg(FileBasedLockStrateg$FileLocker, boolean); protected final boolean acquireLock(java.io.File); protected final void releaseLock(java.io.File); private static void debugLocking(String); private int incrementLock(java.io.File); } org/apache/ivy/plugins/lock/FileBasedLockStrateg$FileLocker.class package org.apache.ivy.plugins.lock;...
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Mon Apr 20 08:41:37 UTC 2015
    - 1.2M bytes
    - Viewed (1)
Back to top