Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Unlock (0.27 sec)

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

        Lock lockA = factory.newReentrantReadWriteLock(OtherOrder.FIRST).readLock();
        Lock lockB = factory.newReentrantLock(OtherOrder.SECOND);
    
        lockA.lock();
        lockA.lock();
        lockB.lock();
        lockB.lock();
        lockA.unlock();
        lockA.unlock();
        lockB.unlock();
        lockB.unlock();
      }
    
    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)
  2. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

     *
     * <ul>
     *   <li>for an unnested {@code lock()} and {@code unlock()}, a cycle detecting lock takes 38ns as
     *       opposed to the 24ns taken by a plain lock.
     *   <li>for nested locking, the cost increases with the depth of the nesting:
     *       <ul>
     *         <li>2 levels: average of 64ns per lock()/unlock()
     *         <li>3 levels: average of 77ns per lock()/unlock()
     *         <li>4 levels: average of 99ns per lock()/unlock()
    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. android/guava/src/com/google/common/util/concurrent/Monitor.java

        }
        final 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.
    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)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

             * holding a lock. Still, it would be nice to avoid somehow.
             */
            lock.lock();
            try {
              currentFuture.cancel(mayInterruptIfRunning);
            } finally {
              lock.unlock();
            }
          }
    
          @Override
          public boolean isCancelled() {
            lock.lock();
            try {
              return currentFuture.isCancelled();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/CacheTesting.java

            drainRecencyQueue(segment);
          }
        }
      }
    
      static void drainRecencyQueue(Segment<?, ?> segment) {
        segment.lock();
        try {
          segment.cleanUp();
        } finally {
          segment.unlock();
        }
      }
    
      static void drainReferenceQueues(Cache<?, ?> cache) {
        if (hasLocalCache(cache)) {
          drainReferenceQueues(toLocalCache(cache));
        }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 16.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        Lock lockA = factory.newReentrantReadWriteLock(OtherOrder.FIRST).readLock();
        Lock lockB = factory.newReentrantLock(OtherOrder.SECOND);
    
        lockA.lock();
        lockA.lock();
        lockB.lock();
        lockB.lock();
        lockA.unlock();
        lockA.unlock();
        lockB.unlock();
        lockB.unlock();
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (1)
  7. guava-tests/test/com/google/common/cache/CacheTesting.java

            drainRecencyQueue(segment);
          }
        }
      }
    
      static void drainRecencyQueue(Segment<?, ?> segment) {
        segment.lock();
        try {
          segment.cleanUp();
        } finally {
          segment.unlock();
        }
      }
    
      static void drainReferenceQueues(Cache<?, ?> cache) {
        if (hasLocalCache(cache)) {
          drainReferenceQueues(toLocalCache(cache));
        }
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 16.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/hash/MacHashFunctionTest.java

        byte[] key = fillByteArray(80, 0xaa);
        String data = "Test Using Larger Than Block-Size Key - Hash Key First";
    
        checkSha1("aa4ae5e15272d00e95705637ce8a3b55ed402112", key, data);
      }
    
      public void testRfc2202_hmacSha1_case7() {
        byte[] key = fillByteArray(80, 0xaa);
        String data = "Test Using Larger Than Block-Size Key and Larger Than One Block-Size Data";
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 13.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/io/ByteStreams.java

              "reached end of stream after reading " + read + " bytes; " + len + " bytes expected");
        }
      }
    
      /**
       * Discards {@code n} bytes of data from the input stream. This method will block until the full
       * amount has been skipped. Does not close the stream.
       *
       * @param in the input stream to read from
       * @param n the number of bytes to skip
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Jan 17 18:59:58 GMT 2024
    - 29.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/base/SuppliersTest.java

                  if (System.nanoTime() - t0 > timeout) {
                    thrown.set(
                        new TimeoutException(
                            "timed out waiting for other threads to block"
                                + " synchronizing on supplier"));
                    break;
                  }
                  Thread.yield();
                }
                count.getAndIncrement();
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 18.1K bytes
    - Viewed (0)
Back to top