Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,027 for concurrent (0.17 sec)

  1. docs/en/docs/async.md

    ### 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">
    
    Then it's your turn, you place your order of 2 very fancy burgers for your crush and you. 🍔🍔
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  2. impl/maven-core/src/test/java/org/apache/maven/lifecycle/internal/builder/multithreaded/SmartProjectComparatorTest.java

    package org.apache.maven.lifecycle.internal.builder.multithreaded;
    
    import java.util.Arrays;
    import java.util.List;
    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.AtomicReference;
    
    import org.apache.maven.execution.ProjectDependencyGraph;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Aug 06 12:03:40 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  3. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    
    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Param;
    import com.google.caliper.api.Footprint;
    import com.google.caliper.api.SkipThisScenarioException;
    import com.google.common.util.concurrent.AbstractFutureBenchmarks.Facade;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3K bytes
    - Viewed (0)
  4. 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)
  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. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt

     */
    package okhttp3.internal.concurrent
    
    import assertk.assertThat
    import assertk.assertions.isCloseTo
    import assertk.assertions.isEmpty
    import assertk.assertions.isEqualTo
    import assertk.assertions.isTrue
    import java.lang.Thread.UncaughtExceptionHandler
    import java.util.concurrent.LinkedBlockingDeque
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import org.junit.jupiter.api.AfterEach
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    import java.io.IOException
    import java.util.concurrent.CopyOnWriteArrayList
    import java.util.concurrent.LinkedBlockingDeque
    import java.util.concurrent.TimeUnit
    import okhttp3.internal.concurrent.Task
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.RoutePlanner.ConnectResult
    import okhttp3.internal.connection.RoutePlanner.Plan
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  9. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/internal/concurrent/TaskQueue;->scheduleAndDecide$okhttp(Lokhttp3/internal/concurrent/Task;JZ)Z
    HSPLokhttp3/internal/concurrent/TaskQueue;->shutdown()V
    HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;-><init>(Ljava/util/concurrent/ThreadFactory;)V
    HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->coordinatorNotify(Lokhttp3/internal/concurrent/TaskRunner;)V
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (1)
  10. 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)
Back to top