Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 185 for locks (0.03 seconds)

  1. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock(); // will throw an IllegalStateException
       * lockC.lock(); // will throw an IllegalStateException
       *
       * lockA.lock(); // reentrant acquisition is okay
       * }
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for Striped.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for Striped.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  4. .teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt

                // we only allow 1 promotion job running at the same time to avoid website xml conflicts
                feature {
                    type = "JetBrains.SharedResources"
                    param("locks-param", "WebsiteReleasesXml writeLock")
                }
            }
        }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 30 04:44:29 GMT 2026
    - 2.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      }
    
      /**
       * 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
      public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) {
    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)
  6. doc/godebug.md

    distribution that disables transparent huge pages altogether.
    
    Go 1.22 added contention on runtime-internal locks to the [`mutex`
    profile](/pkg/runtime/pprof#Profile). Contention on these locks is always
    reported at `runtime._LostContendedRuntimeLock`. Complete stack traces of
    runtime locks can be enabled with the [`runtimecontentionstacks`
    setting](/pkg/runtime#hdr-Environment_Variables). These stack traces have
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 15:49:10 GMT 2026
    - 26K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/Queues.java

        int added = 0;
        while (added < numElements) {
          // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
          // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
          added += q.drainTo(buffer, numElements - added);
          if (added < numElements) { // not enough elements immediately available; will have to poll
            E e = q.poll(deadline - System.nanoTime(), NANOSECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/Queues.java

        int added = 0;
        while (added < numElements) {
          // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
          // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
          added += q.drainTo(buffer, numElements - added);
          if (added < numElements) { // not enough elements immediately available; will have to poll
            E e = q.poll(deadline - System.nanoTime(), NANOSECONDS);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

       * cancelled without a call to {@code cancel}, such as by calling {@code
       * setFuture(cancelledFuture)}.
       *
       * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or
       * acquire other locks, risking deadlocks.
       */
      @CanIgnoreReturnValue
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        @RetainedLocalRef Object localValue = value();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/Monitor.java

        }
        ReentrantLock lock = this.lock;
        lock.lock();
    
        boolean satisfied = false;
        try {
          return satisfied = guard.isSatisfied();
        } finally {
          if (!satisfied) {
            lock.unlock();
          }
        }
      }
    
      /**
       * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the
       * lock, but does not wait for the guard to be satisfied.
    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)
Back to Top