Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for ThreadPriorityCheck (0.15 sec)

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

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(final Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) {
          super(
              new Runnable() {
                @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  2. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

      class Interruptenator extends Thread {
        final AtomicBoolean shutdown;
    
        Interruptenator(final Thread interruptee) {
          this(interruptee, new AtomicBoolean(false));
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) {
          super(
              new Runnable() {
                @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/MoreFilesTest.java

       *
       * <p>We can only test this with a file system that supports SecureDirectoryStream, because it's
       * not possible to protect against this if the file system doesn't.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      public void testDirectoryDeletion_directorySymlinkRace() throws IOException {
        int iterations = isAndroid() ? 100 : 5000;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 16:07:00 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

        return this;
      }
    
      /**
       * 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>.
       *
       * @param priority the priority for new Threads created with this ThreadFactory
       * @return this for the builder pattern
       */
      @CanIgnoreReturnValue
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:50:54 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/MoreFilesTest.java

       *
       * <p>We can only test this with a file system that supports SecureDirectoryStream, because it's
       * not possible to protect against this if the file system doesn't.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      public void testDirectoryDeletion_directorySymlinkRace() throws IOException {
        int iterations = isAndroid() ? 100 : 5000;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

        final AtomicDouble at = new AtomicDouble(1.0);
        Thread t =
            newStartedThread(
                new CheckedRunnable() {
                  @Override
                  @SuppressWarnings("ThreadPriorityCheck") // doing our best to test for races
                  public void realRun() {
                    while (!at.compareAndSet(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
    - 10.3K bytes
    - Viewed (0)
  10. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top