- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,141 for executors (0.14 sec)
-
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) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
private var writer = Http2Writer(bytesOut, client) private val outFrames: MutableList<OutFrame> = ArrayList() private val inFrames: BlockingQueue<InFrame> = LinkedBlockingQueue() private var port = 0 private val executor = Executors.newSingleThreadExecutor(threadFactory("MockHttp2Peer")) private var serverSocket: ServerSocket? = null private var socket: Socket? = null fun setClient(client: Boolean) { if (this.client == client) return
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public class ExecutionSequencerTest extends TestCase { ExecutorService executor; private ExecutionSequencer serializer; private SettableFuture<@Nullable Void> firstFuture; private TestCallable firstCallable; @Override public void setUp() throws Exception { executor = Executors.newCachedThreadPool(); serializer = ExecutionSequencer.create(); firstFuture = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
public class ExecutionSequencerTest extends TestCase { ExecutorService executor; private ExecutionSequencer serializer; private SettableFuture<@Nullable Void> firstFuture; private TestCallable firstCallable; @Override public void setUp() throws Exception { executor = Executors.newCachedThreadPool(); serializer = ExecutionSequencer.create(); firstFuture = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
class RelayTest { @TempDir var tempDir: File? = null private val executor = Executors.newCachedThreadPool(threadFactory("RelayTest")) private val metadata: ByteString = "great metadata!".encodeUtf8() private lateinit var file: File @BeforeEach fun setUp() { file = File(tempDir, "test") } @AfterEach fun tearDown() { executor.shutdown() } @Test fun singleSource() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
*/ package org.codelibs.fess.exec; import java.io.File; import java.lang.management.ManagementFactory; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} public void testCompletionFinishesWithDone() { ExecutorService executor = Executors.newFixedThreadPool(10); for (int i = 0; i < 50000; i++) { final AbstractFuture<String> future = new AbstractFuture<String>() {}; final AtomicReference<String> errorMessage = Atomics.newReference(); executor.execute( new Runnable() { @Override public void run() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheUnsupportedTypesIntegrationTest.groovy
DefaultThreadFactory | ThreadFactory | "java.util.concurrent.Executors.defaultThreadFactory()" executorServiceTypeOnCurrentJvm() | Executor | "java.util.concurrent.Executors.newSingleThreadExecutor().tap { shutdown() }"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 28.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/tooling/internal/provider/continuous/ContinuousBuildActionExecutorTest.groovy
def textOutputFactory = new TestStyledTextOutputFactory() def executorService = Executors.newCachedThreadPool() def fileSystemIsWatchingAnyLocations = true def virtualFileSystem = Stub(BuildLifecycleAwareVirtualFileSystem) { isWatchingAnyLocations() >> { fileSystemIsWatchingAnyLocations } } def executer = executer() private File file = new File('file').absoluteFile
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 12.7K bytes - Viewed (0)