Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 22 for ThreadPriorityCheck (0.15 sec)

  1. guava-tests/test/com/google/common/collect/QueuesTest.java

        } catch (InterruptedException expected) {
          // we indeed waited; a slow thread had enough time to interrupt us
        }
      }
    
      // same as above; uninterruptible version
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      private void assertUninterruptibleDrained(BlockingQueue<Object> q) {
        assertEquals(0, Queues.drainUninterruptibly(q, ImmutableList.of(), 0, 10, MILLISECONDS));
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

       * get() call. As measurements of time are prone to flakiness, it tries to assert based on ranges
       * derived from observing how much time actually passed for various operations.
       */
      @SuppressWarnings("ThreadPriorityCheck")
      @AndroidIncompatible // Thread.suspend
      public void testToString_delayedTimeout() throws Exception {
        Integer javaVersion = Ints.tryParse(JAVA_SPECIFICATION_VERSION.value());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        OLD {
          @Override
          <T> Facade<T> newFacade() {
            return new OldAbstractFutureFacade<T>();
          }
        };
    
        abstract <T> Facade<T> newFacade();
      }
    
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      static void awaitWaiting(Thread t) {
        while (true) {
          Thread.State state = t.getState();
          switch (state) {
            case RUNNABLE:
            case BLOCKED:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

        a.set(0, 1.0);
        Thread t =
            newStartedThread(
                new CheckedRunnable() {
                  @Override
                  @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
                  public void realRun() {
                    while (!a.compareAndSet(0, 2.0, 3.0)) {
                      Thread.yield();
                    }
                  }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        }
      }
    
      /**
       * Delays, via Thread.sleep, for the given millisecond delay, but if the sleep is shorter than
       * specified, may re-sleep or yield until time elapses.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait?
      static void delay(long millis) throws InterruptedException {
        long startTime = System.nanoTime();
        long ns = millis * 1000 * 1000;
        for (; ; ) {
    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-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        }
      }
    
      /**
       * Delays, via Thread.sleep, for the given millisecond delay, but if the sleep is shorter than
       * specified, may re-sleep or yield until time elapses.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait?
      static void delay(long millis) throws InterruptedException {
        long startTime = System.nanoTime();
        long ns = millis * 1000 * 1000;
        for (; ; ) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

          fail("awaitTermination failed to trigger after shutdown()");
        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

       * removal listener), or else is not affected by the {@code clear()} (and therefore exists in the
       * cache afterward).
       */
      @GwtIncompatible // QueuingRemovalListener
    
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      public void testRemovalNotification_clear_basher() throws InterruptedException {
        // If a clear() happens close to the end of computation, one of two things should happen:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

          fail("awaitTermination failed to trigger after shutdown()");
        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

       * {@code getUnchecked}, and threads with an odd index will call {@code get}. If the cache throws
       * exceptions, this difference may be visible in the returned List.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      private static <K> List<Object> doConcurrentGet(
          final LoadingCache<K, ?> cache,
          final K key,
          int nThreads,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 86.3K bytes
    - Viewed (0)
Back to top