import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * Manages the lifecycle of some thread-safe service or resource.
 */
public class ServiceLifecycle implements AsyncStoppable {
    private enum State {RUNNING, STOPPING, STOPPED}

    private final String displayName;
    private final Lock lock = new ReentrantLock();

    private final ManagedExecutor executor;
    private final ServiceLifecycle lifecycle;

    public DefaultAsyncConsumerActionExecutor(ConsumerActionExecutor actionExecutor, ExecutorFactory executorFactory) {
        this.actionExecutor = actionExecutor;
        executor = executorFactory.create("Connection worker");
        lifecycle = new ServiceLifecycle(actionExecutor.getDisplayName());
    }

    @Override

 */

package org.gradle.tooling.internal.consumer.async

import org.gradle.test.fixtures.concurrent.ConcurrentSpec

class ServiceLifecycleTest extends ConcurrentSpec {
    def lifecycle = new ServiceLifecycle("[service]")

    def "can use service when not stopped"() {
        def action = Mock(Runnable)

        when:
        lifecycle.use(action)

        then:
        1 * action.run()
        0 * _._

Class <org.gradle.tooling.internal.consumer.async.ServiceLifecycle$State> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (ServiceLifecycle.java:0)
Class <org.gradle.tooling.internal.consumer.async.ServiceLifecycle> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (ServiceLifecycle.java:0)