Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 56 for blocked (0.07 sec)

  1. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  2. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/base/SuppliersTest.java

        long timeout = SECONDS.toNanos(60);
    
        Supplier<Boolean> supplier =
            new Supplier<Boolean>() {
              boolean isWaiting(Thread thread) {
                switch (thread.getState()) {
                  case BLOCKED:
                  case WAITING:
                  case TIMED_WAITING:
                    return true;
                  default:
                    return false;
                }
              }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

               * the lock) until after it's scheduled and the runningTask field is set.
               */
              if (requireNonNull(runningTask).isCancelled()) {
                // task may have been cancelled while blocked on the lock.
                return;
              }
              AbstractScheduledService.this.runOneIteration();
            } catch (Throwable t) {
              restoreInterruptIfIsInterruptedException(t);
              try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

               * the lock) until after it's scheduled and the runningTask field is set.
               */
              if (requireNonNull(runningTask).isCancelled()) {
                // task may have been cancelled while blocked on the lock.
                return;
              }
              AbstractScheduledService.this.runOneIteration();
            } catch (Throwable t) {
              restoreInterruptIfIsInterruptedException(t);
              try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.34.md

    - Extended resources backed by DRA feature allowed cluster operator to specify `extendedResourceName` in `DeviceClass`, and application operator to continue using extended resources in pod's requests to request for DRA devices matching the DeviceClass.
      
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 27 10:36:10 UTC 2025
    - 292.8K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java

                TimeZone.setDefault(originalDefault);
            }
        }
    
        public void test_processDBFluteSystem_unlocksAndLocks() {
            // This test verifies that the DBFluteSystem is properly unlocked and locked
            // during the process, though we can't directly test the lock state
    
            // When
            try {
                curtainBeforeHook.processDBFluteSystem();
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/primitives/Ints.java

        //     in all.
        // (3) "Successive". We can consider that we are exchanging a block of size d (a[0..d-1]) with a
        //     block of size n-d (a[d..n-1]), where in general these blocks have different sizes. If we
        //     imagine a line separating the first block from the second, we can proceed by exchanging
        //     the smaller of these blocks with the far end of the other one. That leaves us with a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/MutableClassToInstanceMap.java

       * default initial capacity and load factor.
       */
      public static <B extends @Nullable Object> MutableClassToInstanceMap<B> create() {
        return new MutableClassToInstanceMap<>(new HashMap<Class<? extends @NonNull B>, B>());
      }
    
      /**
       * Returns a new {@code MutableClassToInstanceMap} instance backed by a given empty {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 22:10:29 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/ImmutableCollection.java

          other[size] = null;
        }
        copyIntoArray(other, 0);
        return other;
      }
    
      /** If this collection is backed by an array of its elements in insertion order, returns it. */
      @Nullable Object @Nullable [] internalArray() {
        return null;
      }
    
      /**
       * If this collection is backed by an array of its elements in insertion order, returns the offset
       * where this collection's elements start.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 21.4K bytes
    - Viewed (0)
Back to top