- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 2,153 for executors (0.16 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
@Override protected void setUp() { final ExecutorService executor = Executors.newSingleThreadExecutor(); tearDownStack.addTearDown( new TearDown() { @Override public void tearDown() { executor.shutdownNow(); } }); sleeper = new SleepingRunnable(1000); delayedFuture = executor.submit(sleeper, true); tearDownStack.addTearDown(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
*/ class SocksProxy { private val executor = Executors.newCachedThreadPool(threadFactory("SocksProxy")) private var serverSocket: ServerSocket? = null private val connectionCount = AtomicInteger() private val openSockets = Collections.newSetFromMap(ConcurrentHashMap<Socket, Boolean>()) fun play() { serverSocket = ServerSocket(0) executor.execute {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 7.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
import com.google.common.annotations.GwtCompatible; import com.google.j2objc.annotations.WeakOuter; import java.util.concurrent.Callable; import java.util.concurrent.Executors; import java.util.concurrent.RunnableFuture; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Oct 01 17:18:04 UTC 2021 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
public final class SimpleTimeLimiter implements TimeLimiter { private final ExecutorService executor; private SimpleTimeLimiter(ExecutorService executor) { this.executor = checkNotNull(executor); } /** * Creates a TimeLimiter instance using the given executor service to execute method calls. * * <p><b>Warning:</b> using a bounded executor may be counterproductive! If the thread pool fills
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 27 14:21:11 UTC 2023 - 9.7K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
import java.time.Duration; import java.util.EnumSet; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@link FakeTicker}. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 06 14:40:46 UTC 2024 - 6.4K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
import java.net.InetAddress import java.net.InetSocketAddress import java.net.ServerSocket import java.security.PrivateKey import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import java.util.concurrent.Future import javax.net.ServerSocketFactory import javax.net.SocketFactory import javax.net.ssl.SSLSocket import okhttp3.Handshake import okhttp3.Handshake.Companion.handshake
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 7.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
} }; private TimeLimiter service; private static final ExecutorService executor = Executors.newFixedThreadPool(1); @Override protected void setUp() throws Exception { super.setUp(); service = SimpleTimeLimiter.create(executor); } public void testNewProxy_goodMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
import static org.junit.Assert.assertThrows; import com.google.common.testing.NullPointerTester; import java.lang.Thread.UncaughtExceptionHandler; import java.util.Locale; import java.util.concurrent.Executors; import java.util.concurrent.ThreadFactory; import junit.framework.TestCase; /** * Tests for ThreadFactoryBuilder. * * @author Kurt Alfred Kluever * @author Martin Buchholz */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/internal/file/archive/AbstractArchiveFileTreeTest.java
import java.nio.charset.Charset; import java.util.ArrayList; import java.util.List; import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.stream.Collectors; import static org.gradle.api.file.FileVisitorUtil.assertCanStopVisiting; import static org.gradle.api.file.FileVisitorUtil.assertVisits;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jul 28 16:17:59 UTC 2023 - 6.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
for (ProjectSegment segment : projectBuilds) { segment.getSession().setParallel(parallel); } ExecutorService executor = Executors.newFixedThreadPool(nThreads, new BuildThreadFactory()); CompletionService<ProjectSegment> service = new ExecutorCompletionService<>(executor); // Currently disabled ThreadOutputMuxer muxer = null; // new ThreadOutputMuxer( analyzer.getProjectBuilds(), System.out );
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Sep 22 09:07:17 UTC 2023 - 9.4K bytes - Viewed (0)