Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 747 for units (0.03 sec)

  1. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * @throws NullPointerException if the specified element is null
       */
      @CanIgnoreReturnValue // pushed down from class to method
      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) {
        checkNotNull(unit);
        return offer(e); // never need to block
      }
    
      /**
       * Inserts the specified element into this priority queue. As the queue is unbounded this method
       * will never block.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      @ParametricNullness
      final V blockingGet(long timeout, TimeUnit unit)
          throws InterruptedException, TimeoutException, ExecutionException {
        // NOTE: if timeout < 0, remainingNanos will be < 0 and we will fall into the while(true) loop
        // at the bottom and throw a timeoutexception.
        long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit.
        long remainingNanos = timeoutNanos;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              return -1L
            }
          },
        )
        return null
      }
    
      private fun awaitTcpConnect(
        timeout: Long,
        unit: TimeUnit,
      ): ConnectResult? {
        if (tcpConnectsInFlight.isEmpty()) return null
    
        val result = connectResults.poll(timeout, unit) ?: return null
    
        tcpConnectsInFlight.remove(result.plan)
    
        return result
      }
    
      private fun cancelInFlightConnects() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. maven-tests/src/test/java/com/squareup/okhttp3/maventest/AppTest.java

     */
    package com.squareup.okhttp3.maventest;
    
    import mockwebserver3.MockResponse;
    import mockwebserver3.MockWebServer;
    import okhttp3.Headers;
    import org.junit.Test;
    
    import java.io.IOException;
    
    /**
     * Unit test for simple App.
     */
    public class AppTest {
      private final MockWebServer mockWebServer = new MockWebServer();
    
      @Test
      public void testApp() throws IOException {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jul 12 12:05:57 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  5. src/test/resources/test_app.xml

    <components>
    	<include path="convention.xml" />
    	<include path="lastaflute.xml" />
    	
    	<!-- Register systemProperties for test environment -->
    	<component name="systemProperties" class="org.codelibs.fess.unit.TestSystemProperties" />
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 390 bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ForwardingLock.java

      }
    
      @Override
      public boolean tryLock() {
        return delegate().tryLock();
      }
    
      @Override
      public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
        return delegate().tryLock(time, unit);
      }
    
      @Override
      public void unlock() {
        delegate().unlock();
      }
    
      @Override
      public Condition newCondition() {
        return delegate().newCondition();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  7. android/guava-testlib/test/com/google/common/testing/anotherpackage/ForwardingWrapperTesterTest.java

            Charset charset,
            TimeUnit unit,
            Class<?> cls,
            Joiner joiner,
            Pattern pattern,
            UnsignedInteger ui,
            UnsignedLong ul,
            StringBuilder sb,
            Predicate<?> pred,
            Function<?, ?> func,
            Object obj) {
          delegate.foo(
              s, r, n, it, b, eq, e, in, c, ord, charset, unit, cls, joiner, pattern, ui, ul, sb, pred,
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 15.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/Monitor.java

        }
      }
    
      /**
       * Returns unit.toNanos(time), additionally ensuring the returned value is not at risk of
       * overflowing or underflowing, by bounding the value between 0 and (Long.MAX_VALUE / 4) * 3.
       * Actually waiting for more than 219 years is not supported!
       */
      private static long toSafeNanos(long time, TimeUnit unit) {
        long timeoutNanos = unit.toNanos(time);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws TimeoutException, InterruptedException, ExecutionException {
    
        long timeoutNanos = unit.toNanos(timeout);
        if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) {
          return super.get(timeout, unit);
        }
        // Waiting 68 years should be enough for any program.
        return super.get(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractService.java

        Service.super.awaitRunning(timeout);
      }
    
      @Override
      public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
        if (monitor.enterWhenUninterruptibly(hasReachedRunning, timeout, unit)) {
          try {
            checkCurrentState(RUNNING);
          } finally {
            monitor.leave();
          }
        } else {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
Back to top