- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 625 for executors (0.15 sec)
-
platforms/software/build-init/src/main/java/org/gradle/buildinit/plugins/internal/maven/PomProjectInitDescriptor.java
private final WorkerExecutor executor; private FileCollection mavenClasspath; public PomProjectInitDescriptor(MavenSettingsProvider mavenSettingsProvider, DocumentationRegistry documentationRegistry, WorkerExecutor executor) { this.settingsProvider = mavenSettingsProvider; this.documentationRegistry = documentationRegistry; this.executor = executor; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 23 19:14:24 UTC 2024 - 6.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
ListenableFuture<? extends V> input, Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { CatchingFuture<V, X> future = new CatchingFuture<>(input, exceptionType, fallback); input.addListener(future, rejectionPropagatingExecutor(executor, future)); return future; } static <X extends Throwable, V extends @Nullable Object> ListenableFuture<V> create(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/CleanUpVirtualFileSystemAfterBuild.java
private final ManagedExecutor executor; private CompletableFuture<Void> pendingCleanup = CompletableFuture.completedFuture(null); public CleanUpVirtualFileSystemAfterBuild(ExecutorFactory executorFactory, GradleUserHomeScopeServiceRegistry userHomeServiceRegistry) { this.executor = executorFactory.create("VFS cleanup");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ExecutorPolicy.java
import java.lang.reflect.UndeclaredThrowableException; import java.util.concurrent.Callable; import java.util.concurrent.atomic.AtomicReference; /** * Controls the behavior of an executor when a task is executed and an executor is stopped. */ public interface ExecutorPolicy { /** * Special behavior when a task is executed. * * The Runnable's run() needs to be called from this method. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.3K bytes - Viewed (0) -
okhttp-android/src/test/kotlin/okhttp3/android/ShadowDnsResolver.kt
val flags: Int, val callback: DnsResolver.Callback<List<InetAddress>>, ) @Implementation fun query( network: Network?, domain: String, nsType: Int, flags: Int, executor: Executor, cancellationSignal: CancellationSignal?, callback: DnsResolver.Callback<List<InetAddress>>, ) { responder(Request(network, domain, nsType, flags, callback)) } companion object {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 22 20:07:09 UTC 2024 - 1.7K bytes - Viewed (0) -
maven-plugin-api/src/main/java/org/apache/maven/plugin/lifecycle/Phase.java
} // -- void setConfiguration( Object ) /** * Set the goals to execute within the phase. * * @param executions a executions object. */ public void setExecutions(java.util.List<Execution> executions) { this.executions = executions; } // -- void setExecutions( java.util.List ) /** * Set the ID of this phase, e.g., * <code>generate-sources</code>.
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Jun 10 19:51:46 UTC 2024 - 3.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/test/groovy/org/gradle/integtests/fixtures/executer/AbstractGradleExecuterTest.groovy
when: executer.requireDaemon() def allArgs = executer.getAllArgs() then: allArgs.contains("--daemon") !allArgs.contains("--no-daemon") } def "when requireDaemon is not called, arguments should contain --no-daemon"() { when: def allArgs = executer.getAllArgs() then: !allArgs.contains("--daemon")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/junit/AbstractJUnitTestClassProcessor.java
private static final Logger LOGGER = LoggerFactory.getLogger(AbstractJUnitTestClassProcessor.class); private final ActorFactory actorFactory; private Actor resultProcessorActor; private Action<String> executor; public AbstractJUnitTestClassProcessor(ActorFactory actorFactory) { this.actorFactory = actorFactory; } @Override public void startProcessing(TestResultProcessor resultProcessor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
ListenableFuture<? extends V> input, Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { CatchingFuture<V, X> future = new CatchingFuture<>(input, exceptionType, fallback); input.addListener(future, rejectionPropagatingExecutor(executor, future)); return future; } static <X extends Throwable, V extends @Nullable Object> ListenableFuture<V> create(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
private String processOutput; private InputStream processStdOutput; @Override public void connectStreams(Process process, String processName, Executor executor) { processStdOutput = process.getInputStream(); } @Override @SuppressWarnings("DefaultCharset") public void start() { if (processStdOutput == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0)