Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 977 for concurrents (0.06 sec)

  1. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. 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)
  3. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

    import java.net.HttpURLConnection
    import java.net.URL
    import java.nio.ByteBuffer
    import java.util.concurrent.CompletableFuture
    import java.util.concurrent.ExecutionException
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.Executors
    import java.util.concurrent.TimeUnit
    import kotlin.coroutines.cancellation.CancellationException
    import okio.Buffer
    import org.junit.After
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 24 13:19:43 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Dns.kt

     * implementation to use a different DNS server, to prefer IPv6 addresses, to prefer IPv4 addresses,
     * or to force a specific known IP address.
     *
     * Implementations of this interface must be safe for concurrent use.
     */
    fun interface Dns {
      /**
       * Returns the IP addresses of `hostname`, in the order they will be attempted by OkHttp. If a
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. okhttp-android/src/main/kotlin/okhttp3/android/AndroidAsyncDns.kt

    import android.net.DnsResolver
    import android.net.Network
    import android.os.Build
    import androidx.annotation.RequiresApi
    import java.net.InetAddress
    import java.net.UnknownHostException
    import java.util.concurrent.Executors
    import okhttp3.AsyncDns
    import okhttp3.ExperimentalOkHttpApi
    
    /**
     * DNS implementation based on android.net.DnsResolver, which submits a request for
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 10:07:48 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/MapMakerTest.java

    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.base.Function;
    import com.google.common.testing.NullPointerTester;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 15 17:36:06 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. futures/failureaccess/pom.xml

      <version>1.0.2</version>
      <packaging>bundle</packaging>
      <name>Guava InternalFutureFailureAccess and InternalFutures</name>
      <description>
        Contains
        com.google.common.util.concurrent.internal.InternalFutureFailureAccess and
        InternalFutures. Most users will never need to use this artifact. Its
        classes are conceptually a part of Guava, but they're in this separate
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 17 02:24:23 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  8. docs/bucket/lifecycle/README.md

    ```
    mc ilm rule add --noncurrent-expire-days 365 --prefix "user-uploads/" myminio/mydata
    ```
    
    ### 3.2 Automatic removal of noncurrent versions keeping only most recent ones after noncurrent days
    
    It is possible to configure automatic removal of older noncurrent versions keeping only the most recent `N` using `NewerNoncurrentVersions`.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 09 01:45:38 UTC 2024
    - 9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ServiceManagerBridge.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.collect.ImmutableMultimap;
    import com.google.common.util.concurrent.Service.State;
    
    /**
     * Superinterface of {@link ServiceManager} to introduce a bridge method for {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.testing.MockFutureListener;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top