Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 20 for TryLock (0.27 seconds)

  1. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 23 15:26:56 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  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 {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  3. 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 33.4.0 (but since 30.0 in the JRE flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  4. 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
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 13K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        assertFalse(lockA.tryLock());
    
        thread.releaseLockAndFinish();
        assertTrue(lockA.tryLock());
      }
    
      public void testReentrantWriteLock_tryLock() throws Exception {
        LockingThread thread = new LockingThread(writeLockA);
        thread.start();
    
        thread.waitUntilHoldingLock();
        assertFalse(writeLockA.tryLock());
        assertFalse(readLockA.tryLock());
    
        thread.releaseLockAndFinish();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        assertFalse(lockA.tryLock());
    
        thread.releaseLockAndFinish();
        assertTrue(lockA.tryLock());
      }
    
      public void testReentrantWriteLock_tryLock() throws Exception {
        LockingThread thread = new LockingThread(writeLockA);
        thread.start();
    
        thread.waitUntilHoldingLock();
        assertFalse(writeLockA.tryLock());
        assertFalse(readLockA.tryLock());
    
        thread.releaseLockAndFinish();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Monitor.java

        ReentrantLock lock = this.lock;
        if (!fair && lock.tryLock()) {
          return true;
        }
        boolean interrupted = Thread.interrupted();
        try {
          long startTime = System.nanoTime();
          for (long remainingNanos = timeoutNanos; ; ) {
            try {
              return lock.tryLock(remainingNanos, NANOSECONDS);
            } catch (InterruptedException interrupt) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/MapMakerInternalMap.java

        }
    
        // reference queues, for garbage collection cleanup
    
        /** Cleanup collected entries when the lock is available. */
        void tryDrainReferenceQueues() {
          if (tryLock()) {
            try {
              maybeDrainReferenceQueues();
            } finally {
              unlock();
            }
          }
        }
    
        @GuardedBy("this")
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/cache/LocalCache.java

          }
        }
    
        // reference queues, for garbage collection cleanup
    
        /** Cleanup collected entries when the lock is available. */
        void tryDrainReferenceQueues() {
          if (tryLock()) {
            try {
              drainReferenceQueues();
            } finally {
              unlock();
            }
          }
        }
    
        /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  10. 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)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
Back to Top