Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 277 for untimed (0.03 sec)

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

                   * case we ever switch to JUnit 4:
                   */
                  fail();
                }
              }
            });
      }
    
      // TODO(cpovirk): promote to Uninterruptibles, and add untimed version
      private static void joinUninterruptibly(Thread thread, long timeout, TimeUnit unit) {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Unit tests for {@link Futures#getChecked(Future, Class)}. */
    @NullUnmarked
    public class FuturesGetCheckedTest extends TestCase {
      // Boring untimed-get tests:
    
      public void testGetCheckedUntimed_success() throws TwoArgConstructorException {
        assertEquals("foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class));
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

                   * case we ever switch to JUnit 4:
                   */
                  fail();
                }
              }
            });
      }
    
      // TODO(cpovirk): promote to Uninterruptibles, and add untimed version
      private static void joinUninterruptibly(Thread thread, long timeout, TimeUnit unit) {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        } else if (isTryEnter(method)) {
          assertFalse(desc, isTimed(method));
          assertTrue(desc, isBoolean(method));
          assertFalse(desc, isInterruptible(method));
        } else if (isWaitFor(method)) {
          assertTrue(desc, isGuarded(method));
          assertEquals(desc, isTimed(method), isBoolean(method));
        } else { // any other enterXxx method
          assertEquals(desc, isTimed(method), isBoolean(method));
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          return "SynchronizedHelper";
        }
      }
    
      private static boolean mightBeAndroid() {
        String runtime = System.getProperty("java.runtime.name", "");
        // I have no reason to believe that `null` is possible here, but let's make sure we don't crash:
        return runtime == null || runtime.contains("Android");
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/exception/CommandExecutionExceptionTest.java

            Throwable cause = new RuntimeException("Runtime error");
            CommandExecutionException exception = new CommandExecutionException(null, cause);
    
            assertNotNull(exception);
            assertNull(exception.getMessage());
            assertEquals(cause, exception.getCause());
            assertEquals("Runtime error", exception.getCause().getMessage());
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/job/ExecJob.java

                    final ScheduledJob job = (ScheduledJob) jobRuntime.getParameterMap().get(Constants.SCHEDULED_JOB);
                    if (job != null) {
                        prop.setProperty("job.runtime.id", job.getId());
                        prop.setProperty("job.runtime.name", job.getName());
                    }
                }
                prop.store(out, cmdList.toString());
            } catch (final IOException e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

        }
      }
    
      // Gets and Timed Gets
      //
      // * Be responsive to interruption
      // * Don't create Waiter nodes if you aren't going to park, this helps reduce contention on
      //   waitersField.
      // * Future completion is defined by when #valueField becomes non-null/non DelegatingToFuture
      // * Future completion can be observed if the waitersField field contains a TOMBSTONE
    
      // Timed Get
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/testing/GcFinalization.java

        // e.g. using Thread#activeCount()
        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
Back to top