Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 453 for CONCURRENT (1.35 sec)

  1. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentNavigableMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.LinkedBlockingDeque;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  2. docs/en/docs/async.md

    To see the difference, imagine the following story about burgers:
    
    ### Concurrent Burgers { #concurrent-burgers }
    
    You go with your crush to get fast food, you stand in line while the cashier takes the orders from the people in front of you. 😍
    
    <img src="/img/async/concurrent-burgers/concurrent-burgers-01.png" class="illustration">
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okhttp3.internal.concurrent.assertLockHeld
    import okhttp3.internal.concurrent.assertLockNotHeld
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.http.ExchangeCodec
    import okhttp3.internal.http.RealInterceptorChain
    import okhttp3.internal.http1.Http1ExchangeCodec
    import okhttp3.internal.http2.ConnectionShutdownException
    import okhttp3.internal.http2.ErrorCode
    import okhttp3.internal.http2.FlowControlListener
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

    import java.net.Socket
    import java.util.concurrent.TimeUnit
    import javax.net.SocketFactory
    import javax.net.ssl.HostnameVerifier
    import javax.net.ssl.HttpsURLConnection
    import javax.net.ssl.SSLSocketFactory
    import okhttp3.internal.RecordingOkAuthenticator
    import okhttp3.internal.concurrent.TaskFaker
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.withLock
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:44:44 UTC 2025
    - 17K bytes
    - Viewed (0)
  6. src/main/java/jcifs/util/SmbCircuitBreaker.java

    import java.util.Deque;
    import java.util.List;
    import java.util.concurrent.ConcurrentLinkedDeque;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  7. internal/event/targetlist.go

    	CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets
    	CurrentQueue     int   // Populated if target has a store.
    	TotalEvents      int64
    	FailedEvents     int64 // Number of failed events per target
    }
    
    // TargetList - holds list of targets indexed by target ID.
    type TargetList struct {
    	// The number of concurrent async Send calls to all targets
    	currentSendCalls  atomic.Int64
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

    import android.annotation.SuppressLint
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogManager
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import okhttp3.internal.buildConnectionPool
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.withLock
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseManager.java

    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  10. README.md

    - **Logging Abstraction** (`org.codelibs.core.log`) - Flexible logging system supporting JCL (Jakarta Commons Logging) and JUL (Java Util Logging)
    - **Concurrent Utilities** (`org.codelibs.core.concurrent`) - Thread-safe collections and concurrency helpers using modern concurrent APIs
    - **Crypto & Security** (`org.codelibs.core.crypto`, `org.codelibs.core.security`) - Basic cryptographic utilities, message digest operations, and secure random generation
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sun Aug 31 02:56:02 UTC 2025
    - 12.7K bytes
    - Viewed (0)
Back to top