Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for Unlock (0.14 sec)

  1. 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)
  2. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  3. 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) {
        boolean interrupted = false;
    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)
  4. 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)
  5. 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)
  6. android/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 May 03 12:43:13 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 18.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        manager.addListener(
            new ServiceManager.Listener() {
              @Override
              public void failure(Service service) {
                failEnter.countDown();
                // block until after the service manager is shutdown
                Uninterruptibles.awaitUninterruptibly(failLeave);
              }
            },
            directExecutor());
        manager.startAsync();
        afterStarted.countDown();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        return method.getName().startsWith("enter") || method.getName().startsWith("tryEnter");
      }
    
      /** Identifies just tryEnterXxx methods (a subset of {@link #isAnyEnter}), which never block. */
      private static boolean isTryEnter(Method method) {
        return method.getName().startsWith("tryEnter");
      }
    
      /**
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 27.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/io/CharSource.java

     * that provide readers that are:
     *
     * <ul>
     *   <li><b>Finite:</b> Many operations, such as {@link #length()} and {@link #read()}, will either
     *       block indefinitely or fail if the source creates an infinite reader.
     *   <li><b>Non-destructive:</b> A <i>destructive</i> reader will consume or otherwise alter the
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 17 14:35:11 GMT 2023
    - 22.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/ByteSource.java

     * that provide streams that are:
     *
     * <ul>
     *   <li><b>Finite:</b> Many operations, such as {@link #size()} and {@link #read()}, will either
     *       block indefinitely or fail if the source creates an infinite stream.
     *   <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 17 14:35:11 GMT 2023
    - 26.2K bytes
    - Viewed (0)
Back to top