Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for restore (0.19 sec)

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

         *
         * <p>If the Thread in use is interrupted before or during execution of the tasks in {@link
         * #queue}, the Executor will complete its tasks, and then restore the interruption. This means
         * that once the Thread returns to the Executor that this Executor composes, the interruption
         * will still be present. If the composed Executor is an ExecutorService, it can respond to
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

       * method.
       */
      public void callAndAssertWaits(String methodName, Object conditionLikeObject) throws Exception {
        checkNotNull(methodName);
        checkNotNull(conditionLikeObject);
        // TODO: Restore the following line when Monitor.hasWaiters() no longer acquires the lock.
        // assertEquals(false, invokeMethod("hasWaiters", conditionLikeObject));
        sendRequest(methodName, conditionLikeObject);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/TestThread.java

       * method.
       */
      public void callAndAssertWaits(String methodName, Object conditionLikeObject) throws Exception {
        checkNotNull(methodName);
        checkNotNull(conditionLikeObject);
        // TODO: Restore the following line when Monitor.hasWaiters() no longer acquires the lock.
        // assertEquals(false, invokeMethod("hasWaiters", conditionLikeObject));
        sendRequest(methodName, conditionLikeObject);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/RangeTest.java

            .addEqualityGroup(Range.all(), Range.all())
            .addEqualityGroup("Phil")
            .testEquals();
      }
    
      @GwtIncompatible // TODO(b/148207871): Restore once Eclipse compiler no longer flakes for this.
      public void testLegacyComparable() {
        Range<LegacyComparable> range = Range.closed(LegacyComparable.X, LegacyComparable.Y);
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 10:16:44 GMT 2024
    - 24.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/graph/DirectedGraphConnections.java

          addedPredecessor = true;
        } else if (previousValue instanceof PredAndSucc) {
          // Restore previous PredAndSucc object.
          adjacentNodeValues.put(node, previousValue);
          addedPredecessor = false;
        } else if (previousValue != PRED) { // successor
          // Do NOT use method parameter value 'unused'. In directed graphs, successors store the value.
          adjacentNodeValues.put(node, new PredAndSucc(previousValue));
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 18K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/RangeTest.java

            .addEqualityGroup(Range.all(), Range.all())
            .addEqualityGroup("Phil")
            .testEquals();
      }
    
      @GwtIncompatible // TODO(b/148207871): Restore once Eclipse compiler no longer flakes for this.
      public void testLegacyComparable() {
        Range<LegacyComparable> range = Range.closed(LegacyComparable.X, LegacyComparable.Y);
      }
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Feb 21 10:16:44 GMT 2024
    - 24.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

       * roughly) 2.5s longer. (2.5s is also the maximum length of time we will wait for a timed get
       * that is expected to succeed; the fact that the numbers match is only a coincidence.) See the
       * comment below for how to restore the fast but hang-y version.
       */
      @J2ktIncompatible
      @GwtIncompatible // used only in GwtIncompatible tests
      private static List<String> conditionalPseudoTimedGetUninterruptibly(
          TestFutureBatch inputs,
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

       * roughly) 2.5s longer. (2.5s is also the maximum length of time we will wait for a timed get
       * that is expected to succeed; the fact that the numbers match is only a coincidence.) See the
       * comment below for how to restore the fast but hang-y version.
       */
      @J2ktIncompatible
      @GwtIncompatible // used only in GwtIncompatible tests
      private static List<String> conditionalPseudoTimedGetUninterruptibly(
          TestFutureBatch inputs,
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

              }
            });
    
        // Run those tasks together.
        fakePool.runAll();
    
        // Check that the interruption of a SequentialExecutor's task is restored to the thread once
        // it is yielded. Clear the bit while checking so that the test doesn't hose JUnit or some other
        // test case.
        assertThat(Thread.interrupted()).isTrue();
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

              pred.next = succ;
              if (pred.thread == null) { // We raced with another node that unlinked pred. Restart.
                continue restart;
              }
            } else if (!ATOMIC_HELPER.casWaiters(this, curr, succ)) { // We are unlinking head
              continue restart; // We raced with an add or complete
            }
            curr = succ;
          }
          break;
        }
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
Back to top