Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,019 for concurrently (0.05 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

    import java.util.concurrent.Callable;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.ReentrantLock;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ObjectArrays.java

       *
       * <p>This method returns the elements in the order they are returned by the collection's
       * iterator.
       *
       * <p>TODO(kevinb): support concurrently modified collections?
       *
       * @param c the collection for which to return an array of elements
       * @param array the array in which to place the collection elements
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  3. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

    import java.util.concurrent.Callable;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit test for {@link FakeTicker}.
     *
     * @author Jige Yu
     */
    @GwtCompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/LongAddable.java

     * the License.
     */
    
    package com.google.common.cache;
    
    import com.google.common.annotations.GwtCompatible;
    
    /**
     * Abstract interface for objects that can concurrently add longs.
     *
     * @author Louis Wasserman
     */
    @GwtCompatible
    interface LongAddable {
      void increment();
    
      void add(long x);
    
      long sum();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 885 bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/ObjectArrays.java

       *
       * <p>This method returns the elements in the order they are returned by the collection's
       * iterator.
       *
       * <p>TODO(kevinb): support concurrently modified collections?
       *
       * @param c the collection for which to return an array of elements
       * @param array the array in which to place the collection elements
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  6. docs/multi-tenancy/README.md

    ![Example-2](https://github.com/minio/minio/blob/master/docs/screenshots/Example-2.jpg?raw=true)
    
    ## 2. Distributed Deployment
    
    To host multiple tenants in a distributed environment, run several distributed MinIO Server instances concurrently.
    
    ### 2.1 Host Multiple Tenants on Multiple Drives (Erasure Code)
    
    Use the following commands to host 3 tenants on a 4-node distributed configuration:
    
    ```sh
    export MINIO_ROOT_USER=<TENANT1_ACCESS_KEY>
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  7. CHANGELOG.md

    **OkHttp now supports Happy Eyeballs ([RFC 8305][rfc_8305]) for IPv4+IPv6 networks.** It attempts
    both IPv6 and IPv4 connections concurrently, keeping whichever connects first.
    
    **We’ve improved our Kotlin APIs.** You can skip the builder:
    
    ```kotlin
    val request = Request(
      url = "https://cash.app/".toHttpUrl(),
    )
    ```
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 19:32:33 UTC 2025
    - 31.6K bytes
    - Viewed (2)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
       * These steps are split so callers can call [connectTcp] on a background thread if attempting
       * multiple plans concurrently.
       */
      interface Plan {
        val isReady: Boolean
    
        fun connectTcp(): ConnectResult
    
        fun connectTlsEtc(): ConnectResult
    
        fun handleSuccess(): RealConnection
    
        fun cancel()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/LongAdder.java

       * Resets variables maintaining the sum to zero. This method may be a useful alternative to
       * creating a new adder, but is only effective if there are no concurrent updates. Because this
       * method is intrinsically racy, it should only be used when it is known that no threads are
       * concurrently updating.
       */
      public void reset() {
        internalReset(0L);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  10. src/arena/arena.go

    // it is no longer referenced, so it must be kept alive (see runtime.KeepAlive)
    // until any memory allocated from it is no longer needed.
    //
    // An Arena must never be used concurrently by multiple goroutines.
    type Arena struct {
    	a unsafe.Pointer
    }
    
    // NewArena allocates a new arena.
    func NewArena() *Arena {
    	return &Arena{a: runtime_arena_newArena()}
    }
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Oct 12 20:23:36 UTC 2022
    - 4.3K bytes
    - Viewed (0)
Back to top