antBuilder.getProject().addBuildListener(loggingAdapter);
        stoppable.add(antBuilder);
        return antBuilder;
    }

    @Override
    public void close() {
        stoppable.stop();
    }

                }
            });
            stoppable.add((Stoppable) () -> {
                try {
                    fileLockContentionHandler.stop(lockId);
                } catch (Exception e) {
                    throw new RuntimeException("Unable to stop listening for file lock requests for " + displayName, e);
                }
            });
            stoppable.add((Stoppable) () -> {
                lock = null;

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.internal.remote.internal;

import org.gradle.internal.concurrent.Stoppable;
import org.gradle.internal.dispatch.Dispatch;
import org.gradle.internal.dispatch.Receive;

/**
 * <p>A messaging endpoint which allows push-style dispatch and pull-style receive.
 *

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.tooling.internal.consumer.connection;

import org.gradle.internal.concurrent.Stoppable;
import org.gradle.tooling.BuildAction;
import org.gradle.tooling.internal.consumer.PhasedBuildAction;
import org.gradle.tooling.internal.consumer.TestExecutionRequest;

import org.gradle.internal.classpath.InstrumentedExecutionAccess
import org.gradle.internal.concurrent.Stoppable
import org.gradle.internal.service.scopes.ListenerService


@ListenerService
internal
class InstrumentedExecutionAccessListenerRegistry(
    instrumentedExecutionAccessListener: InstrumentedExecutionAccessListener
) : Stoppable {

    init {
        InstrumentedExecutionAccess.setListener(instrumentedExecutionAccessListener)

 */
package org.gradle.api.internal.artifacts.verification.signatures;

import org.gradle.internal.concurrent.Stoppable;
import org.gradle.security.internal.PublicKeyService;

import java.io.File;
import java.util.Set;

public interface SignatureVerificationService extends Stoppable {
    void verify(File origin, File signature, Set<String> trustedKeys, Set<String> ignoredKeys, SignatureVerificationResultBuilder result);

 * limitations under the License.
 */

package org.gradle.api.internal.tasks.testing;

import org.gradle.internal.concurrent.Stoppable;

/**
 * A processor for executing tests. Implementations are not required to be thread-safe.
 */
public interface TestClassProcessor extends Stoppable {
    /**
     * Performs any initialisation which this processor needs to perform.
     *

 * limitations under the License.
 */
package org.gradle.kotlin.dsl.provider

import org.gradle.internal.concurrent.Stoppable
import java.util.Collections.synchronizedList


open class ClassPathModeExceptionCollector : Stoppable {

    private
    val collection: MutableList<Exception> = synchronizedList(mutableListOf<Exception>())

    val exceptions: List<Exception>

 * limitations under the License.
 */

package org.gradle.tooling.internal.consumer.connection;

import org.gradle.internal.concurrent.Stoppable;

/**
 * Implementations must be thread-safe.
 */
public interface ConsumerActionExecutor extends Stoppable {
    /**
     * Blocks until all actions have completed.
     */
    @Override
    void stop();

    String getDisplayName();

import org.gradle.api.logging.Logging;
import org.gradle.api.model.ObjectFactory;
import org.gradle.internal.Cast;
import org.gradle.internal.concurrent.CompositeStoppable;
import org.gradle.internal.concurrent.Stoppable;
import org.gradle.internal.operations.BuildOperationContext;
import org.gradle.internal.operations.BuildOperationDescriptor;
import org.gradle.internal.operations.BuildOperationRunner;