- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for cancellationToken (0.26 sec)
-
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/CancellationToken.java
* * <p>All implementations of this interface are required to be thread safe.</p> * * @since 2.1 */ public interface CancellationToken { /** * Gets whether cancellation has been requested for this token. * @return Cancellation status. */ boolean isCancellationRequested();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/InternalCancellationTokenAdapter.java
private final InternalCancellationToken cancellationToken; public InternalCancellationTokenAdapter(InternalCancellationToken cancellationToken) { this.cancellationToken = cancellationToken; } @Override public boolean isCancellationRequested() { return cancellationToken.isCancellationRequested(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/DefaultCancellableOperationManagerTest.groovy
def cancellationToken = new DefaultBuildCancellationToken() def monitor = new DefaultCancellableOperationManager(executorService, new DisconnectableInputStream(new PipedInputStream(writeEnd)), cancellationToken) def "can exit without cancel"() { when: monitor.monitorInput {} then: !cancellationToken.isCancellationRequested()
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/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonCancelForwarderTest.groovy
def forwarder def createForwarder() { forwarder = new DaemonCancelForwarder(dispatch, cancellationToken) forwarder.start() } def setup() { createForwarder() } def "cancel is forwarded when received before stop"() { when: cancellationToken.cancel() forwarder.stop() then: receiveCancel() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/loader/CachingToolingImplementationLoaderTest.groovy
def impl2 = loader.create(distribution2, loggerFactory, progressListener, params, cancellationToken) then: impl == connection1 impl2 == connection2 1 * target.create(distribution1, loggerFactory, progressListener, params, cancellationToken) >> connection1 1 * target.create(distribution2, loggerFactory, progressListener, params, cancellationToken) >> connection2
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 09:39:07 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/continuous/ContinuousBuildTriggerHandler.java
private volatile boolean changeArrived; public ContinuousBuildTriggerHandler( BuildCancellationToken cancellationToken, ContinuousExecutionGate continuousExecutionGate, Duration continuousBuildQuietPeriod ) { this.cancellationToken = cancellationToken; this.continuousExecutionGate = continuousExecutionGate; this.quietPeriod = continuousBuildQuietPeriod; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.5K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/connection/LazyConsumerActionExecutorTest.groovy
_ * action.parameters >> params 1 * params.cancellationToken >> cancellationToken 1 * params.buildProgressListener >> buildProgressListener 1 * action.run(consumerConnection) 0 * _._ then: _ * action2.parameters >> params _ * params.cancellationToken >> cancellationToken
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 4.4K bytes - Viewed (0) -
platforms/core-runtime/tooling-api-provider/src/main/java/org/gradle/tooling/internal/provider/DefaultConnection.java
Object results = connection.run(action, buildCancellationToken, providerParameters); return new ProviderBuildResult<>(Cast.uncheckedNonnullCast(results)); } /** * This is used by consumers 4.4 and later */ @Override public <T> BuildResult<T> run(InternalBuildActionVersion2<T> action, InternalCancellationToken cancellationToken, BuildParameters operationParameters)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 13.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonCancelForwarder.java
private final Runnable cancellationCallback; private final BuildCancellationToken cancellationToken; public DaemonCancelForwarder(final Dispatch<? super Cancel> dispatch, BuildCancellationToken cancellationToken) { this.cancellationToken = cancellationToken; cancellationCallback = new Runnable() { @Override public void run() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/steps/CancelExecutionStep.java
private final BuildCancellationToken cancellationToken; private final Step<? super C, ? extends R> delegate; public CancelExecutionStep( BuildCancellationToken cancellationToken, Step<? super C, ? extends R> delegate ) { this.cancellationToken = cancellationToken; this.delegate = delegate; } @SuppressWarnings("Finally")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:33 UTC 2024 - 1.8K bytes - Viewed (0)