- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 173 for stoppable (0.26 sec)
-
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/Stoppable.java
* limitations under the License. */ package org.gradle.internal.concurrent; /** * Represents an object which performs concurrent activity. */ public interface Stoppable { /** * <p>Requests a graceful stop of this object. Blocks until all concurrent activity has been completed.</p> * * <p>If this object has already been stopped, this method does nothing.</p> */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 989 bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/CompositeStoppable.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.9K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/CompositeStoppableTest.groovy
class CompositeStoppableTest extends Specification { private final CompositeStoppable stoppable = new CompositeStoppable() def stopsAllElementsOnStop() { Stoppable a = Mock() Stoppable b = Mock() stoppable.add(a) stoppable.add(b) when: stoppable.stop() then: 1 * a.stop() 1 * b.stop() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 2.5K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/AsyncStoppable.java
*/ package org.gradle.internal.concurrent; /** * A {@link Stoppable} object whose stop process can be performed asynchronously. */ public interface AsyncStoppable extends Stoppable { /** * <p>Requests that this stoppable commence a graceful stop. Does not block. You should call {@link * Stoppable#stop} to wait for the stop process to complete.</p> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/cli/RunBuildAction.java
private final ServiceRegistry sharedServices; private final Stoppable stoppable; public RunBuildAction( BuildActionExecutor<BuildActionParameters, ClientBuildRequestContext> executor, StartParameterInternal startParameter, GradleLauncherMetaData clientMetaData, long startTime, BuildActionParameters buildActionParameters, ServiceRegistry sharedServices, Stoppable stoppable) { this.executor = executor;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultWorkerProcess.java
return Optional.ofNullable(execHandle.getExecResult()); } private void cleanup() { CompositeStoppable stoppable; lock.lock(); try { stoppable = CompositeStoppable.stoppable(connection, new Stoppable() { @Override public void stop() { execHandle.abort(); } }, acceptor);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 14:39:33 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/RunBuildActionTest.groovy
final long startTime = 90 final BuildActionParameters parameters = Mock() final ServiceRegistry sharedServices = Mock() final Stoppable stoppable = Mock() final RunBuildAction action = new RunBuildAction(client, startParameter, clientMetaData, startTime, parameters, sharedServices, stoppable) def runsBuildUsingDaemon() { when: action.run() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/ActionExecutionWorker.java
clientConnection.addUnrecoverableErrorHandler(new Action<Throwable>() { @Override public void execute(Throwable throwable) { if (action instanceof Stoppable) { ((Stoppable) action).stop(); } } }); ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/ProjectBuilderImpl.java
project.getExtensions().getExtraProperties().set( "ProjectBuilder.stoppable", stoppable( (Stoppable) workerLeaseService::runAsIsolatedTask, (Stoppable) workerLease::leaseFinish, buildServices, buildTreeState, buildSessionState,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:36 UTC 2024 - 15.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/DefaultGradleUserHomeScopeServiceRegistry.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 5.9K bytes - Viewed (0)