Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for Unlock (0.07 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();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. 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();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Striped.java

         * error-prone code like:
         *
         * Striped<Lock> stripedLock = Striped.lazyWeakXXX(...)'
         * Iterable<Lock> locks = stripedLock.bulkGet(keys);
         * for (Lock lock : locks) {
         *   lock.lock();
         * }
         * operation();
         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

        }
      }
    
      /**
       * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)}
       * uninterruptibly.
       *
       * @since 30.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static boolean tryLockUninterruptibly(Lock lock, Duration timeout) {
        return tryLockUninterruptibly(lock, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        MEDIUM_DELAY_MS = SHORT_DELAY_MS * 10;
        LONG_DELAY_MS = SHORT_DELAY_MS * 200;
      }
    
      /**
       * Returns a timeout in milliseconds to be used in tests that verify that operations block or time
       * out.
       */
      long timeoutMillis() {
        return SHORT_DELAY_MS / 4;
      }
    
      /** Returns a new Date instance representing a time delayMillis milliseconds in the future. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/MinMaxPriorityQueue.java

     * the queue exceeds that value, the queue automatically removes its greatest element according to
     * its comparator (which might be the element that was just added). This is different from
     * conventional bounded queues, which either block or reject new elements when full.
     *
     * <p>This implementation is based on the <a
     * href="http://portal.acm.org/citation.cfm?id=6621">min-max heap</a> developed by Atkinson, et al.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  }
                }
              });
          try {
            future.get();
          } catch (Throwable t) {
            // Ignore, we just wanted to block.
          }
          String error = errorMessage.get();
          assertNull(error, error);
        }
        executor.shutdown();
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  8. 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();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  9. 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";
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/Queues.java

       * Queue<E> queue = Queues.synchronizedQueue(MinMaxPriorityQueue.<E>create());
       * ...
       * queue.add(element);  // Needn't be in synchronized block
       * ...
       * synchronized (queue) {  // Must synchronize on queue!
       *   Iterator<E> i = queue.iterator(); // Must be in synchronized block
       *   while (i.hasNext()) {
       *     foo(i.next());
       *   }
       * }
       * }</pre>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
Back to top