Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for TryLock (0.22 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        thread.start();
    
        thread.waitUntilHoldingLock();
        assertFalse(writeLockA.tryLock());
        assertFalse(readLockA.tryLock());
    
        thread.releaseLockAndFinish();
        assertTrue(writeLockA.tryLock());
        assertTrue(readLockA.tryLock());
      }
    
      public void testReentrantReadLock_tryLock() throws Exception {
        LockingThread thread = new LockingThread(readLockA);
        thread.start();
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (1)
  2. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

        }
    
        @Override
        public boolean tryLock() {
          aboutToAcquire(this);
          try {
            return super.tryLock();
          } finally {
            lockStateChanged(this);
          }
        }
    
        @Override
        public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException {
          aboutToAcquire(this);
          try {
            return super.tryLock(timeout, unit);
          } finally {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Dec 15 19:31:54 GMT 2023
    - 35.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        thread.start();
    
        thread.waitUntilHoldingLock();
        assertFalse(writeLockA.tryLock());
        assertFalse(readLockA.tryLock());
    
        thread.releaseLockAndFinish();
        assertTrue(writeLockA.tryLock());
        assertTrue(readLockA.tryLock());
      }
    
      public void testReentrantReadLock_tryLock() throws Exception {
        LockingThread thread = new LockingThread(readLockA);
        thread.start();
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (0)
  4. android/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) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ForwardingLock.java

        delegate().lockInterruptibly();
      }
    
      @Override
      public boolean tryLock() {
        return delegate().tryLock();
      }
    
      @Override
      public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
        return delegate().tryLock(time, unit);
      }
    
      @Override
      public void unlock() {
        delegate().unlock();
      }
    
      @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  6. 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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 14.4K bytes
    - Viewed (0)
  7. internal/cachevalue/cache.go

    			return v.v, v.e
    		}
    	}
    
    	// Fetch new value.
    	if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 && (v.e == nil || t.opts.CacheError) {
    		if t.updating.TryLock() {
    			go func() {
    				defer t.updating.Unlock()
    				t.update()
    			}()
    		}
    		return v.v, v.e
    	}
    
    	// Get lock. Either we get it or we wait for it.
    	t.updating.Lock()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K 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
    Plain Text
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 13K bytes
    - Viewed (0)
  9. 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;
    Java
    - Registered: Sun Apr 21 03:35:09 GMT 2024
    - Last Modified: Wed Feb 28 23:31:09 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        WeakReference<Object> garbage = new WeakReference<>(new Object());
        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
        for (Striped<?> striped : strongImplementations()) {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 8.4K bytes
    - Viewed (0)
Back to top