Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for ThreadPriorityCheck (0.06 sec)

  1. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(Thread interruptee, AtomicBoolean shutdown) {
          super(
              new Runnable() {
                @Override
                public void run() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  2. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(Thread interruptee, AtomicBoolean shutdown) {
          super(
              new Runnable() {
                @Override
                public void run() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

      }
    
      /**
       * Sets the priority for new threads created with this ThreadFactory.
       *
       * <p><b>Warning:</b> relying on the thread scheduler is <a
       * href="http://errorprone.info/bugpattern/ThreadPriorityCheck">discouraged</a>.
       *
       * <p><b>Java 21+ users:</b> use {@link Thread.Builder.OfPlatform#priority(int)} instead.
       *
       * @param priority the priority for new Threads created with this ThreadFactory
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/base/SuppliersTest.java

                  if (isWaiting(thread)) {
                    waitingThreads++;
                  }
                }
                return waitingThreads;
              }
    
              @Override
              @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
              public Boolean get() {
                // Check that this method is called exactly once, by the first
                // thread to synchronize.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/base/SuppliersTest.java

                  if (isWaiting(thread)) {
                    waitingThreads++;
                  }
                }
                return waitingThreads;
              }
    
              @Override
              @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
              public Boolean get() {
                // Check that this method is called exactly once, by the first
                // thread to synchronize.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            } else {
              afterRanInterruptiblyFailure(error);
            }
          }
        }
      }
    
      @SuppressWarnings({
        "Interruption", // We are restoring an interrupt on this thread.
        "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait.
      })
      private void waitForInterrupt(Thread currentThread) {
        /*
         * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  7. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  8. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  9. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  10. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 37.8K bytes
    - Viewed (0)
Back to top