Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 56 for Plock (0.13 sec)

  1. 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. */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.2K bytes
    - Viewed (0)
  2. 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();
      }
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        valueRef.clear();
        assertNotSame(value, map.get(key, loader));
        assertEquals(1, loader.getCount());
        assertEquals(1, segment.count);
      }
    
      @AndroidIncompatible // Perhaps emulator clock does not update between the two get() calls?
      public void testComputeExpiredEntry() throws ExecutionException {
        CacheBuilder<Object, Object> builder =
            createCacheBuilder().expireAfterWrite(1, TimeUnit.NANOSECONDS);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 112.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        valueRef.clear();
        assertNotSame(value, map.get(key, loader));
        assertEquals(1, loader.getCount());
        assertEquals(1, segment.count);
      }
    
      @AndroidIncompatible // Perhaps emulator clock does not update between the two get() calls?
      public void testComputeExpiredEntry() throws ExecutionException {
        CacheBuilder<Object, Object> builder =
            createCacheBuilder().expireAfterWrite(1, TimeUnit.NANOSECONDS);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 110.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * ListenableFuture} listeners, should take care not to do so while holding a lock. Additionally,
       * as a further line of defense, prefer not to perform any locking inside a task that will be run
       * under {@code directExecutor}: Not only might the wait for a lock be long, but if the running
       * thread was holding a lock, the listener may deadlock or break lock isolation.
       *
       * <p>This instance is equivalent to:
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Striped64.java

       * needed.
       *
       * A single spinlock ("busy") is used for initializing and
       * resizing the table, as well as populating slots with new Cells.
       * There is no need for a blocking lock; when the lock is not
       * available, threads try other slots (or the base).  During these
       * retries, there is increased contention and reduced locality,
       * which is still better than alternatives.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

       * of reads may not be immediately reflected on the algorithm's data structures. These structures
       * are guarded by a lock and operations are applied in batches to avoid lock contention. The
       * penalty of applying the batches is spread across threads so that the amortized cost is slightly
       * higher than performing just the operation without enforcing the capacity constraint.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 91.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/base/Charsets.java

     * @since 1.0
     */
    @GwtCompatible(emulated = true)
    @ElementTypesAreNonnullByDefault
    public final class Charsets {
      private Charsets() {}
    
      /**
       * US-ASCII: seven-bit ASCII, the Basic Latin block of the Unicode character set (ISO646-US).
       *
       * <p><b>Java 7+ users:</b> this constant should be treated as deprecated; use {@link
       * java.nio.charset.StandardCharsets#US_ASCII} instead.
       *
       */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

              ScheduledFuture<?> timer = timeoutFuture.timer;
              timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString()
              String message = "Timed out";
              // This try-finally block ensures that we complete the timeout future, even if attempting
              // to produce the message throws (probably StackOverflowError from delegate.toString())
              try {
                if (timer != null) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  10. 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)
Back to top