- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 291 for executors (0.18 sec)
-
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/DefaultExecutorFactory.java
CompositeStoppable.stoppable(executors).stop(); } finally { executors.clear(); } } @Override public ManagedExecutor create(String displayName) { ManagedExecutor executor = new TrackedManagedExecutor(createExecutor(displayName), new ExecutorPolicy.CatchAndRecordFailures()); executors.add(executor); return executor; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 5.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/invocation/GradleLifecycleUnsupportedTypesIntegrationTest.groovy
Thread | Thread | "Thread.currentThread()" DefaultThreadFactory | ThreadFactory | "java.util.concurrent.Executors.defaultThreadFactory()" executorServiceTypeOnCurrentJvm() | Executor | "java.util.concurrent.Executors.newSingleThreadExecutor().tap { shutdown() }" ByteArrayInputStream | InputStream | "new java.io.ByteArrayInputStream([] as byte[])"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 18:15:52 UTC 2024 - 4.5K 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) -
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) -
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) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/InputTrackingStateTest.kt
package org.gradle.internal.cc.impl import org.junit.Assert import org.junit.Assert.assertFalse import org.junit.Assert.assertTrue import org.junit.Test import java.lang.IllegalStateException import java.util.concurrent.Executors class InputTrackingStateTest { @Test fun `input tracking is enabled by default`() { val state = InputTrackingState() assertTrue(state.isEnabledForCurrentThread()) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ProgressBar.java
import org.gradle.internal.nativeintegration.console.ConsoleMetaData; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class ProgressBar { private static final Logger LOGGER = LoggerFactory.getLogger(ProgressBar.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 5.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
signaled.set(true) } then: poll { assert signaled.get() } } def "there are only two executors: one lock request listener and one release lock action executor"() { def factory = Mock(ExecutorFactory) handler = new DefaultFileLockContentionHandler(factory, addressProvider) when: handler.reservePort()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/core-runtime/concurrent/build.gradle.kts
* limitations under the License. */ plugins { id("gradlebuild.distribution.implementation-java") id("gradlebuild.publish-public-libraries") } description = "Tools to work with managed executors" gradlebuildJava.usedInWorkers() dependencies { api(libs.jsr305) api(projects.stdlibJavaExtensions) implementation(libs.slf4jApi)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 931 bytes - Viewed (0)