Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 351 - 360 of 511 for pulling (0.24 seconds)

  1. android/guava/src/com/google/common/base/Suppliers.java

        @SuppressWarnings("SynchronizeOnNonFinalField")
        public T get() {
          // Another variant of Double Checked Locking.
          //
          // We use two volatile reads. We could reduce this to one by
          // putting our fields into a holder class, but (at least on x86)
          // the extra memory consumption and indirection are more
          // expensive than the extra volatile reads.
          long nanos = expirationNanos;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 31 21:24:28 GMT 2026
    - 16.1K bytes
    - Click Count (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

            // We have metadata retrieval problems, or there are cycles that have been detected
            // so we give this back to the calling code and let them deal with this information
            // appropriately.
    
            if (result.hasMetadataResolutionExceptions()
                    || result.hasVersionRangeViolations()
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 25K bytes
    - Click Count (0)
  3. compat/maven-model-builder/src/site/apt/index.apt

       ({{{./xref/org/apache/maven/model/validation/DefaultModelValidator.html}source}})
    
       []
    
     []
    
    
    * Inheritance Assembly
    
      Inheritance Assembly consists in filling current model empty fields with values taken from parent model.
      It is done in <<<InheritanceAssembler>>> ({{{./apidocs/org/apache/maven/model/inheritance/InheritanceAssembler.html}javadoc}}),
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jan 03 08:42:52 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        assertFalse(service.isRunning());
        assertFalse(service.doStopCalled);
      }
    
      /**
       * The user of this service should call {@link #notifyStarted} and {@link #notifyStopped} after
       * calling {@link #startAsync} and {@link #stopAsync}.
       */
      private static class ManualSwitchedService extends AbstractService {
        boolean doStartCalled = false;
        boolean doStopCalled = false;
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * allow in normal conditions. This is enforced by "throttling" incoming requests as needed. For
       * example, we could compute the appropriate throttle time for an incoming request, and make the
       * calling thread wait for that time.
       *
       * The simplest way to maintain a rate of QPS is to keep the timestamp of the last granted
       * request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        assertFalse(service.isRunning());
        assertFalse(service.doStopCalled);
      }
    
      /**
       * The user of this service should call {@link #notifyStarted} and {@link #notifyStopped} after
       * calling {@link #startAsync} and {@link #stopAsync}.
       */
      private static class ManualSwitchedService extends AbstractService {
        boolean doStartCalled = false;
        boolean doStopCalled = false;
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        // we really just want to wait for the thread to be in the failure callback so we wait for that
        // explicitly instead.
        failEnter.await();
        assertFalse("State should be updated before calling listeners", manager.isHealthy());
        // now we want to stop the services.
        Thread stoppingThread =
            new Thread() {
              @Override
              public void run() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  8. internal/grid/muxclient.go

    	}
    	return m.parent.send(m.ctx, dst)
    }
    
    // RequestStateless will send a single payload request and stream back results.
    // req may not be read/written to after calling.
    // TODO: Not implemented
    func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
    	if m.init {
    		out <- Response{Err: errors.New("mux client already used")}
    	}
    	m.init = true
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  9. doc/go_mem.html

    </p>
    
    <p>
    For example, in this program:
    </p>
    
    <pre>
    var a string
    
    func f() {
    	print(a)
    }
    
    func hello() {
    	a = "hello, world"
    	go f()
    }
    </pre>
    
    <p>
    calling <code>hello</code> will print <code>"hello, world"</code>
    at some point in the future (perhaps after <code>hello</code> has returned).
    </p>
    
    <h3 id="goexit">Goroutine destruction</h3>
    
    <p>
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/collect/Iterables.java

       *
       * <p>The returned iterable's iterator supports {@code remove()} if the iterator of the underlying
       * iterable supports it. Note that it is <i>not</i> possible to delete the last skipped element by
       * immediately calling {@code remove()} on that iterator, as the {@code Iterator} contract states
       * that a call to {@code remove()} before a call to {@code next()} will throw an {@link
       * IllegalStateException}.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 18:35:28 GMT 2025
    - 43.8K bytes
    - Click Count (0)
Back to Top