Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 33 for Rush (0.26 sec)

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

          // afterDone() should be generally fast and only used for cleanup work... but in theory can
          // also be recursive and create StackOverflowErrors
          future.afterDone();
          // push the current set of listeners onto next
          next = future.clearListeners(next);
          future = null;
          while (next != null) {
            Listener curr = next;
            next = next.next;
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractFuture.java

          // afterDone() should be generally fast and only used for cleanup work... but in theory can
          // also be recursive and create StackOverflowErrors
          future.afterDone();
          // push the current set of listeners onto next
          next = future.clearListeners(next);
          future = null;
          while (next != null) {
            Listener curr = next;
            next = next.next;
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/AbstractMapBasedMultiset.java

        }
        return true;
      }
    
      @Override
      public final void clear() {
        backingMap.clear();
        size = 0;
      }
    
      /**
       * Skeleton of per-entry iterators. We could push this down and win a few bytes, but it's complex
       * enough it's not especially worth it.
       */
      abstract class Itr<T extends @Nullable Object> implements Iterator<T> {
        int entryIndex = backingMap.firstIndex();
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Monitor.java

      @GuardedBy("lock")
      private void beginWaitingFor(Guard guard) {
        int waiters = guard.waiterCount++;
        if (waiters == 0) {
          // push guard onto activeGuards
          guard.next = activeGuards;
          activeGuards = guard;
        }
      }
    
      /** Records that the current thread is no longer waiting on the specified guard. */
      @GuardedBy("lock")
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Dec 04 18:22:01 UTC 2023
    - 38.6K bytes
    - Viewed (0)
  5. maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

    import static org.apache.maven.cli.CLIManager.FORCE_INTERACTIVE;
    import static org.apache.maven.cli.CLIManager.NON_INTERACTIVE;
    import static org.apache.maven.cli.ResolveFile.resolveFile;
    
    // TODO push all common bits back to plexus cli and prepare for transition to Guice. We don't need 50 ways to make CLIs
    
    /**
     */
    public class MavenCli {
        public static final String LOCAL_REPO_PROPERTY = "maven.repo.local";
    
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Feb 28 23:31:59 UTC 2024
    - 72.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/ForwardingDeque.java

      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public E pop() {
        return delegate().pop();
      }
    
      @Override
      public void push(@ParametricNullness E e) {
        delegate().push(e);
      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public E removeFirst() {
        return delegate().removeFirst();
      }
    
      @CanIgnoreReturnValue
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Mar 13 14:30:51 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  7. maven-embedder/src/main/java/org/apache/maven/cli/CleanArgument.java

            for (String arg : args) {
                boolean addedToBuffer = false;
    
                if (arg.startsWith("\"")) {
                    // if we're in the process of building up another arg, push it and start over.
                    // this is for the case: "-Dfoo=bar "-Dfoo2=bar two" (note the first unterminated quote)
                    if (currentArg != null) {
                        cleaned.add(currentArg.toString());
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Thu May 02 12:51:05 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ImmutableCollection.java

    @DoNotMock("Use ImmutableList.of or another implementation")
    @GwtCompatible(emulated = true)
    @SuppressWarnings("serial") // we're overriding default serialization
    @ElementTypesAreNonnullByDefault
    // TODO(kevinb): I think we should push everything down to "BaseImmutableCollection" or something,
    // just to do everything we can to emphasize the "practically an interface" nature of this class.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/SourceMetaDataVisitor.java

            }
            findAnnotations(typeDeclaration, currentClass);
    
            allClasses.add(currentClass);
            repository.put(className, currentClass);
    
            classStack.push(currentClass);
            action.run();
            classStack.pop();
        }
    
        private ClassMetaData getCurrentClass() {
            return classStack.peek();
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Sep 21 13:27:02 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          // but work beyond that must take at least one second
          assertTrue(afterBurst >= 1000);
        }
      }
    
      /**
       * This neat test shows that no matter what weights we use in our requests, if we push X amount of
       * permits in a cool state, where X = rate * timeToCoolDown, and we have specified a
       * timeToWarmUp() period, it will cost as the prescribed amount of time. E.g., calling
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 21.6K bytes
    - Viewed (0)
Back to top