Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for hangs (0.2 sec)

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

     * condition becomes true (no "signaling storms" due to use of {@link
     * java.util.concurrent.locks.Condition#signalAll Condition.signalAll}) and that no signals are lost
     * (no "hangs" due to incorrect use of {@link java.util.concurrent.locks.Condition#signal
     * Condition.signal}).
     *
     * <p>A thread is said to <i>occupy</i> a monitor if it has <i>entered</i> the monitor but not yet
    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)
  2. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * this is no worse than what FutureTask does in that situation. Additionally, because the
         * Future was cancelled, its listeners have been run, so its consumers will not hang.
         *
         * Contrast this to the situation we have if setResult() throws, a situation described below.
         */
        I sourceResult;
        try {
          sourceResult = getDone(localInputFuture);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        long hangDelayMillis =
            (expectedOutcome == Outcome.HANG)
                ? EXPECTED_HANG_DELAY_MILLIS
                : UNEXPECTED_HANG_DELAY_MILLIS;
        boolean hung =
            !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS);
        if (hung) {
          assertEquals(expectedOutcome, Outcome.HANG);
        } else {
          assertNull(task.get(UNEXPECTED_HANG_DELAY_MILLIS, TimeUnit.MILLISECONDS));
        }
      }
    
    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)
  4. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * @param terminationTimeout how long to wait for the executor to finish before terminating the
       *     JVM
       * @param timeUnit unit of time for the time parameter
       * @return an unmodifiable version of the input which will not hang the JVM
       */
      @J2ktIncompatible
      @GwtIncompatible // TODO
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static ExecutorService getExitingExecutorService(
    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)
  5. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        long hangDelayMillis =
            (expectedOutcome == Outcome.HANG)
                ? EXPECTED_HANG_DELAY_MILLIS
                : UNEXPECTED_HANG_DELAY_MILLIS;
        boolean hung =
            !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS);
        if (hung) {
          assertEquals(expectedOutcome, Outcome.HANG);
        } else {
          assertNull(task.get(UNEXPECTED_HANG_DELAY_MILLIS, TimeUnit.MILLISECONDS));
        }
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/CacheBuilder.java

       * has elapsed after the entry's creation, or the most recent replacement of its value.
       *
       * <p>When {@code duration} is zero, this method hands off to {@link #maximumSize(long)
       * maximumSize}{@code (0)}, ignoring any otherwise-specified maximum size or weight. This can be
       * useful in testing, or to disable caching temporarily without a code change.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 44.8K bytes
    - Viewed (0)
Back to top