- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,570 for executors (0.23 sec)
-
platforms/jvm/jvm-services/src/integTest/groovy/org/gradle/internal/jvm/inspection/DefaultJvmMetadataDetectorIntegrationTest.groovy
import org.gradle.process.internal.DefaultExecHandleBuilder import org.gradle.test.precondition.Requires import org.gradle.test.preconditions.IntegTestPreconditions import java.util.concurrent.Executors class DefaultJvmMetadataDetectorIntegrationTest extends AbstractIntegrationSpec { @Requires(IntegTestPreconditions.JavaHomeWithDifferentVersionAvailable) def "works on real installation"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 18:25:34 UTC 2024 - 2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy
} } def executor = Mock(Executor) def delegateExecutor = Executors.newFixedThreadPool(threads) operationQueue = new DefaultBuildOperationQueue(false, workerRegistry, executor, new SimpleWorker()) println "expecting ${expectedWorkerCount} concurrent work processors to be started..." when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/LoomTest.kt
*/ package okhttp3 import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isTrue import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.testing.PlatformRule import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt
import assertk.assertions.isEmpty import assertk.assertions.isNotEmpty import java.io.ByteArrayOutputStream import java.io.PrintStream import java.util.concurrent.ExecutorService import java.util.concurrent.Executors import okhttp3.Dispatcher import okhttp3.HttpUrl.Companion.toHttpUrl import okhttp3.OkHttpClient import okhttp3.Request import okhttp3.containers.BasicMockServerTest.Companion.MOCKSERVER_IMAGE
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 11:15:46 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java
this.dispatch = dispatch; this.reader = new BufferedReader(new InputStreamReader(inputStream, Charset.defaultCharset())); this.executor = executor; } @Override public void readAndForwardStdin() { executor.execute(() -> { if (buffer == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 5.8K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/DefaultCancellableOperationManagerTest.groovy
import org.gradle.util.internal.DisconnectableInputStream import spock.lang.AutoCleanup import java.util.concurrent.Executors class DefaultCancellableOperationManagerTest extends ConcurrentSpec { @AutoCleanup def writeEnd = new PipedOutputStream() @AutoCleanup("shutdownNow") def executorService = Executors.newCachedThreadPool() def cancellationToken = new DefaultBuildCancellationToken()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ThrottlingOutputEventListener.java
this(listener, Integer.getInteger("org.gradle.internal.console.throttle", 100), Executors.newSingleThreadScheduledExecutor(), clock); } ThrottlingOutputEventListener(OutputEventListener listener, int throttleMs, ScheduledExecutorService executor, Clock clock) { this.throttleMs = throttleMs; this.listener = listener; this.executor = executor; this.clock = clock; scheduleUpdateNow(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 3.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
import com.google.common.annotations.J2ktIncompatible; import java.util.ArrayList; 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 junit.framework.TestCase; /** * Basher test for {@link AtomicLongMap}. * * @author mike nonemacher */ @J2ktIncompatible // threads
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/concurrent/DefaultAsyncIOScopeFactoryTest.kt
import org.hamcrest.CoreMatchers.sameInstance import org.hamcrest.MatcherAssert.assertThat import org.junit.Test import java.io.IOException import java.util.concurrent.CompletableFuture import java.util.concurrent.Executors import java.util.concurrent.TimeUnit import java.util.concurrent.TimeoutException class DefaultAsyncIOScopeFactoryTest { @Test fun `#io failure is reported upon IOScope#close`() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 3.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testRunIdempotency() throws Exception { final int numThreads = 10; final ExecutorService executor = Executors.newFixedThreadPool(numThreads); for (int i = 0; i < 1000; i++) { final AtomicInteger counter = new AtomicInteger(); final TrustedListenableFutureTask<Integer> task =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K bytes - Viewed (0)