Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for blockedOn (0.04 sec)

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

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 27.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        sendRequest(methodName, arguments);
        assertThat(getResponse(methodName).getThrowable()).isInstanceOf(expected);
      }
    
      /**
       * Causes this thread to call the named method, and asserts that this thread becomes blocked on
       * the lock-like object. The lock-like object must have a method equivalent to {@link
       * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       * state: BLOCKED, WAITING, or TIMED_WAITING.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) {
        long startTime = System.nanoTime();
        for (; ; ) {
          Thread.State s = thread.getState();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
              Thread.yield();
              break;
            case TIMED_WAITING:
              return;
            case TERMINATED:
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

        sendRequest(methodName, arguments);
        assertThat(getResponse(methodName).getThrowable()).isInstanceOf(expected);
      }
    
      /**
       * Causes this thread to call the named method, and asserts that this thread becomes blocked on
       * the lock-like object. The lock-like object must have a method equivalent to {@link
       * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
              Thread.yield();
              break;
            case TIMED_WAITING:
              return;
            case TERMINATED:
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  9. CHANGELOG.md

        intend to ship a public API for these features, but we don't want to hold OkHttp 5.0.0 until
        those APIs are stable.
    
     *  Fix: Change `MockWebServer.close()` to cancel ongoing calls that are blocked on a delay.
    
     *  Upgrade: [Okio 3.13.0][okio_3_13_0].
    
    This release also stabilizes many APIs in the `mockwebserver3` artifact that's new in 5.0.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  10. CHANGELOG/CHANGELOG-1.35.md

    - Added the correct error when eviction is blocked due to the failSafe mechanism of the `DisruptionController`. ([#133097](https://github.com/kubernetes/kubernetes/pull/133097), [@kei01234kei](https://github.com/kei01234kei)) [SIG Apps and Node]
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Dec 17 13:01:55 UTC 2025
    - 228.5K bytes
    - Viewed (0)
Back to top