Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 769 for concurrent1 (0.32 sec)

  1. guava-gwt/test/com/google/common/testing/Testing.gwt.xml

        util.concurrent tests under Guava.
    
        The problem is that GWT responds poorly to two .gwt.xml files in the same
        Java package; see
        https://groups.google.com/g/google-web-toolkit-contributors/c/CqYH59Dt_rQ/m/uVGW1QdUsXUJ
        for details.
    
        The summary is that it ignores one file in favor of the other.
        util.concurrent, like nearly all our packages, has two .gwt.xml files: one
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 19 16:02:36 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java

    import java.lang.reflect.Proxy;
    import java.util.HashSet;
    import java.util.Set;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

    import java.io.InterruptedIOException
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.atomic.AtomicBoolean
    import okio.ByteString
    import okio.Source
    import okio.buffer
    
    internal abstract class BasePublicSuffixList : PublicSuffixList {
      /** True after we've attempted to read the list for the first time. */
      private val listRead = AtomicBoolean(false)
    
      /** Used for concurrent threads reading the list for the first time. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ForwardingLock.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    
    /** Forwarding wrapper around a {@code Lock}. */
    @J2ktIncompatible
    @GwtIncompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ImmediateFuture.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeUnit;
    import java.util.logging.Level;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.Internal.toNanosSaturated;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.time.Duration;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import org.jspecify.annotations.Nullable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Feb 11 17:30:04 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AsyncCallable.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.concurrent.Future;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Computes a value, possibly asynchronously. For an example usage and more information, see {@link
     * Futures.FutureCombiner#callAsync(AsyncCallable, java.util.concurrent.Executor)}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  8. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.util.TreeSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentNavigableMap;
    import java.util.concurrent.DelayQueue;
    import java.util.concurrent.Executor;
    import java.util.concurrent.PriorityBlockingQueue;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.ThreadFactory;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/FakeTicker.java

    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.base.Ticker;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.time.Duration;
    import java.util.concurrent.TimeUnit;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 15:16:19 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

    import assertk.assertions.isCloseTo
    import assertk.assertions.isFalse
    import assertk.assertions.isInstanceOf
    import assertk.assertions.matchesPredicate
    import java.util.Deque
    import java.util.concurrent.ConcurrentLinkedDeque
    import java.util.concurrent.TimeUnit
    import okhttp3.ConnectionEvent.NoNewExchanges
    import okhttp3.internal.connection.ConnectionListener
    import okhttp3.internal.connection.RealConnection
    import okio.IOException
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
Back to top