- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 137 for executorService (0.47 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
import com.google.common.testing.TearDownStack; import com.google.common.util.concurrent.testing.TestingExecutors; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 12.8K bytes - Click Count (0) -
src/test/java/jcifs/util/SecureKeyManagerTest.java
import java.security.GeneralSecurityException; import java.security.SecureRandom; import java.util.Arrays; 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.AtomicInteger; import javax.crypto.SecretKey; import org.junit.jupiter.api.AfterEach;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 14.2K bytes - Click Count (0) -
.teamcity/scripts/CheckBadMerge.java
* java .teamcity/scripts/CheckBadMerge.java < commits.txt * * If any "bad" merge commit is found, it will print the details and exit with non-zero code. */ public class CheckBadMerge { private static final ExecutorService THREAD_POOL = Executors.newCachedThreadPool(); private static final List<String> MONITORED_PATHS = Collections.unmodifiableList(Arrays.asList( "subprojects/docs/src/docs/release/notes.md",
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Mar 30 16:25:09 GMT 2026 - 9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* that once the Thread returns to the Executor that this Executor composes, the interruption * will still be present. If the composed Executor is an ExecutorService, it can respond to * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue. */ @SuppressWarnings("CatchingUnchecked") // sneaky checked exceptionCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 10.6K bytes - Click Count (0) -
docs/changelogs/upgrading_to_okhttp_4.md
* **CipherSuite**: javaName * **ConnectionSpec**: cipherSuites, supportsTlsExtensions, tlsVersions * **Cookie**: domain, expiresAt, hostOnly, httpOnly, name, path, persistent, value * **Dispatcher**: executorService * **FormBody**: size * **Handshake**: cipherSuite, localCertificates, localPrincipal, peerCertificates, peerPrincipal, tlsVersion * **HandshakeCertificates**: keyManager, trustManager * **Headers**: size
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:58:16 GMT 2022 - 10.9K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/script/groovy/GroovyEngineTest.java
import java.util.ArrayList; import java.util.Collections; 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.Future; import java.util.concurrent.atomic.AtomicInteger; import org.codelibs.fess.exception.JobProcessingException;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Mar 15 06:03:38 GMT 2026 - 29.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
val maxRequests: Int = dispatcher.maxRequests dispatcher.maxRequests = 0 val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost dispatcher.maxRequestsPerHost = 0 val executorService: ExecutorService = dispatcher.executorService dispatcher.idleCallback = Runnable { TODO() } val queuedCalls: List<Call> = dispatcher.queuedCalls() val runningCalls: List<Call> = dispatcher.runningCalls()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 49.7K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
import java.util.Collections; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/collect/ConcurrentHashMultisetBenchmark.java
import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Benchmarks for {@link ConcurrentHashMultiset}. * * @author mike nonemacherCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 16.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/graph/ValueGraphTest.java
import static org.junit.Assert.assertThrows; import com.google.common.collect.ImmutableList; import java.util.Set; import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import org.jspecify.annotations.NullUnmarked; import org.junit.After; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.JUnit4;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 17.9K bytes - Click Count (0)