- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 647 for executors (0.17 sec)
-
platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/GradleEnterprisePluginBackgroundJobExecutorsIntegrationTest.groovy
def "jobs can query if they are running on the background executor"() { given: buildFile << """ import ${CompletableFuture.name} def executors = $executors CompletableFuture.runAsync({ println "backgroundJobExecutor.isInBackground = \${executors.isInBackground()}" }, executors.userJobExecutor).exceptionally { e ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 29 16:27:53 UTC 2024 - 7K bytes - Viewed (0) -
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) -
okhttp-android/src/main/kotlin/okhttp3/android/AndroidAsyncDns.kt
internal val resolver = DnsResolver.getInstance() private val executor = Executors.newSingleThreadExecutor() override fun query( hostname: String, callback: AsyncDns.Callback, ) { try { resolver.query( network, hostname, dnsClass.type, DnsResolver.FLAG_EMPTY, executor, null, object : DnsResolver.Callback<List<InetAddress>> {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 10:07:48 UTC 2024 - 2.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/CancelCall.kt
* limitations under the License. */ package okhttp3.recipes.kt import java.io.IOException import java.util.concurrent.Executors import java.util.concurrent.TimeUnit import okhttp3.OkHttpClient import okhttp3.Request class CancelCall { private val executor = Executors.newScheduledThreadPool(1) private val client = OkHttpClient() fun run() { val request = Request.Builder()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.9K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/impl/DefaultGradleEnterprisePluginBackgroundJobExecutors.java
})); } @Override public boolean isInBackground() { return Thread.currentThread() instanceof BackgroundThread; } /** * Shuts the executors down. * All executors immediately stops accepting new jobs. The method blocks until already submitted jobs complete. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 29 16:27:53 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/GradleEnterprisePluginBackgroundJobExecutors.java
import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; /** * Provides executors to run jobs in the background workers. The implementation is provided by Gradle. */ @ServiceScope(Scope.BuildTree.class) public interface GradleEnterprisePluginBackgroundJobExecutors { /** * Returns the executor to run user-provided background jobs in the background workers.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 2.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3.2K bytes - Viewed (0) -
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)