Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for tryLock (0.25 sec)

  1. guava/src/com/google/common/util/concurrent/Monitor.java

        final ReentrantLock lock = this.lock;
        if (!fair && lock.tryLock()) {
          return true;
        }
        boolean interrupted = Thread.interrupted();
        try {
          final long startTime = System.nanoTime();
          for (long remainingNanos = timeoutNanos; ; ) {
            try {
              return lock.tryLock(remainingNanos, TimeUnit.NANOSECONDS);
            } catch (InterruptedException interrupt) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Dec 04 18:22:01 UTC 2023
    - 42.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

            }
          }
        } finally {
          if (interrupted) {
            Thread.currentThread().interrupt();
          }
        }
      }
    
      /**
       * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)}
       * uninterruptibly.
       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 14.4K bytes
    - Viewed (0)
  3. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/DefaultListenerManager.java

                ensureAllWithoutLoggerInitialized();
            }
    
            void maybeAdd(final ListenerDetails listener) {
                if (type.isInstance(listener.listener)) {
                    if (broadcasterLock.tryLock()) {
                        try {
                            checkListenersCanBeAdded();
                            listeners.add(listener);
                            invalidateDispatchCache();
                        } finally {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 10:09:43 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  4. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/ParallelDownloadsIntegrationTest.groovy

                    compile 'test:test3:1.0'
                    compile 'test:test4:1.0'
    
                    components {
                        all { ComponentMetadataDetails details ->
                            if (!lock.tryLock()) {
                                throw new AssertionError("Rule called concurrently")
                            }
                            lock.unlock()
                        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 17:10:15 UTC 2024
    - 13K bytes
    - Viewed (0)
  5. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java

    import java.util.concurrent.atomic.AtomicReference;
    
    import static org.gradle.internal.resources.DefaultResourceLockCoordinationService.lock;
    import static org.gradle.internal.resources.DefaultResourceLockCoordinationService.tryLock;
    import static org.gradle.internal.resources.DefaultResourceLockCoordinationService.unlock;
    
    @ServiceScope(Scope.CrossBuildSession.class)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 09 04:43:28 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

                    acquiredAggregatorLock = aggregator ? aggregatorLock.writeLock() : aggregatorLock.readLock();
                    acquiredProjectLock = getProjectLock(session);
                    if (!acquiredAggregatorLock.tryLock()) {
                        Thread owner = aggregatorLock.getOwner();
                        MojoDescriptor ownerMojo = owner != null ? mojos.get(owner) : null;
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Feb 28 23:31:09 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  7. internal/ringbuffer/ring_buffer.go

    // TryRead read up to len(p) bytes into p like Read but it is not blocking.
    // If it has not succeeded to acquire the lock, it return 0 as n and ErrAcquireLock.
    func (r *RingBuffer) TryRead(p []byte) (n int, err error) {
    	ok := r.mu.TryLock()
    	if !ok {
    		return 0, ErrAcquireLock
    	}
    	defer r.mu.Unlock()
    	if err := r.readErr(true); err != nil {
    		return 0, err
    	}
    	if len(p) == 0 {
    		return 0, r.readErr(true)
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. api/go1.18.txt

    pkg strings, func Clone(string) string
    pkg strings, func Cut(string, string) (string, string, bool)
    pkg strings, func Title //deprecated
    pkg sync, method (*Mutex) TryLock() bool
    pkg sync, method (*RWMutex) TryLock() bool
    pkg sync, method (*RWMutex) TryRLock() bool
    pkg syscall (freebsd-386), type SysProcAttr struct, Pdeathsig Signal
    pkg syscall (freebsd-386-cgo), type SysProcAttr struct, Pdeathsig Signal
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 13K bytes
    - Viewed (0)
  9. subprojects/core/src/main/java/org/gradle/execution/plan/DefaultFinalizedExecutionPlan.java

        private boolean tryLockProjectFor(Node node, List<ResourceLock> resources) {
            ResourceLock toLock = node.getProjectToLock();
            if (toLock == null) {
                return true;
            } else if (toLock.tryLock()) {
                resources.add(toLock);
                return true;
            } else {
                return false;
            }
        }
    
        private void unlockProjectFor(Node node) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Dec 28 21:49:39 UTC 2022
    - 28.1K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/dra/claiminfo_test.go

    				return func() error {
    					if cache.RWMutex.TryLock() {
    						return errors.New("Lock succeeded")
    					}
    					return nil
    				}
    			},
    		},
    		{
    			description: "cache is Rlocked inside a function",
    			funcGen: func(cache *claimInfoCache) func() error {
    				return func() error {
    					if cache.RWMutex.TryRLock() {
    						return errors.New("RLock succeeded")
    					}
    					return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 21K bytes
    - Viewed (0)
Back to top