Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for commands (0.19 sec)

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

      public void testTimeout() throws Exception {
        // Create a service whose executor will never run its commands
        Service service =
            new TestService() {
              @Override
              protected Executor executor() {
                return new Executor() {
                  @Override
                  public void execute(Runnable command) {}
                };
              }
    
              @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

      public void testTimeout() throws Exception {
        // Create a service whose executor will never run its commands
        Service service =
            new TestService() {
              @Override
              protected Executor executor() {
                return new Executor() {
                  @Override
                  public void execute(Runnable command) {}
                };
              }
    
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        }
    
        @Override
        public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
        public ListenableScheduledFuture<?> scheduleAtFixedRate(
            Runnable command, long initialDelay, long period, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

        addCallback(f, callback, directExecutor());
      }
    
      private class CountingSameThreadExecutor implements Executor {
        int runCount = 0;
    
        @Override
        public void execute(Runnable command) {
          command.run();
          runCount++;
        }
      }
    
      private final class MockCallback implements FutureCallback<String> {
        @Nullable private String value = null;
        @Nullable private Throwable failure = null;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 6.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/CompactLinkedHashMap.java

        links = null;
        return result;
      }
    
      /*
       * For discussion of the safety of the following methods for operating on predecessors and
       * successors, see the comments near the end of CompactHashMap, noting that the methods here call
       * link(), which is defined at the end of this file.
       */
    
      private int getPredecessor(int entry) {
        return ((int) (link(entry) >>> 32)) - 1;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 8.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/AbstractMultimapAsMapImplementsMapTest.java

        keyToRemove = map.keySet().iterator().next();
        if (supportsRemove) {
          int initialSize = map.size();
          map.get(keyToRemove);
          map.remove(keyToRemove);
          // This line doesn't hold - see the Javadoc comments above.
          // assertEquals(expectedValue, oldValue);
          assertFalse(map.containsKey(keyToRemove));
          assertEquals(initialSize - 1, map.size());
        } else {
          try {
            map.remove(keyToRemove);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Feb 19 20:34:55 GMT 2024
    - 3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/CompactLinkedHashSet.java

        this.predecessor = null;
        this.successor = null;
        return result;
      }
    
      /*
       * For discussion of the safety of the following methods for operating on predecessors and
       * successors, see the comments near the end of CompactHashMap, noting that the methods here call
       * requirePredecessors() and requireSuccessors(), which are defined at the end of this file.
       */
    
      private int getPredecessor(int entry) {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Feb 05 21:38:59 GMT 2024
    - 9.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/CollectionFuture.java

    abstract class CollectionFuture<V extends @Nullable Object, C extends @Nullable Object>
        extends AggregateFuture<V, C> {
      /*
       * We access this field racily but safely. For discussion of a similar situation, see the comments
       * on the fields of TimeoutFuture. This field is slightly different from the fields discussed
       * there: cancel() never reads this field, only writes to it. That makes the race here completely
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

       * Wraps a {@code Runnable} for submission to the underlying executor. The default implementation
       * delegates to {@link #wrapTask(Callable)}.
       */
      protected Runnable wrapTask(Runnable command) {
        Callable<Object> wrapped = wrapTask(Executors.callable(command, null));
        return () -> {
          try {
            wrapped.call();
          } catch (Exception e) {
            restoreInterruptIfIsInterruptedException(e);
            throwIfUnchecked(e);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 5.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/AbstractMultimapAsMapImplementsMapTest.java

        keyToRemove = map.keySet().iterator().next();
        if (supportsRemove) {
          int initialSize = map.size();
          map.get(keyToRemove);
          map.remove(keyToRemove);
          // This line doesn't hold - see the Javadoc comments above.
          // assertEquals(expectedValue, oldValue);
          assertFalse(map.containsKey(keyToRemove));
          assertEquals(initialSize - 1, map.size());
        } else {
          try {
            map.remove(keyToRemove);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Feb 19 20:34:55 GMT 2024
    - 3K bytes
    - Viewed (0)
Back to top