Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 966 for concurrency (0.13 sec)

  1. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    import com.google.common.util.concurrent.MoreExecutors;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.Delayed;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
    import java.util.concurrent.TimeUnit;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import java.lang.reflect.Method;
    import java.net.URLClassLoader;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import java.lang.reflect.Method;
    import java.net.URLClassLoader;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

    import java.lang.ref.WeakReference;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.logging.Logger;
    import junit.framework.TestCase;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  5. okhttp/api/okhttp.api

    	public final fun maxAge (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
    	public final fun maxAge-LRDsOJo (J)Lokhttp3/CacheControl$Builder;
    	public final fun maxStale (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
    	public final fun maxStale-LRDsOJo (J)Lokhttp3/CacheControl$Builder;
    	public final fun minFresh (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.TimeUnit.SECONDS;
    
    import com.google.common.testing.NullPointerTester;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Executors;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    import com.google.common.collect.Lists;
    import java.util.Collection;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    
    /**
     * Test for {@link WrappingExecutorService}
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ForwardingConcurrentMap.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.concurrent.ConcurrentMap;
    import javax.annotation.CheckForNull;
    
    /**
     * A concurrent map which forwards all its method calls to another concurrent map. Subclasses should
     * override one or more methods to modify the behavior of the backing map as desired per the <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 29 19:42:21 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  9. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

    import java.io.IOException;
    import java.util.Collections;
    import java.util.LinkedHashSet;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.atomic.AtomicInteger;
    import okhttp3.Cache;
    import okhttp3.HttpUrl;
    import okhttp3.MediaType;
    import okhttp3.OkHttpClient;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.errorprone.annotations.DoNotMock;
    import java.util.Collection;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.TimeUnit;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Jun 20 10:45:35 UTC 2021
    - 4.2K bytes
    - Viewed (0)
Back to top