/**
 * Provides logging services per thread.
 */
public class SynchronizedLogging implements LoggingProvider {
    private final ThreadLocal<ThreadLoggingServices> services = new ThreadLocal<ThreadLoggingServices>();
    private final Clock clock;
    private final BuildOperationIdFactory buildOperationIdFactory;

    public SynchronizedLogging(Clock clock, BuildOperationIdFactory buildOperationIdFactory) {
        this.clock = clock;

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

import java.util.concurrent.CopyOnWriteArraySet

public class SynchronizedLoggingTest extends ConcurrentSpec {
    def logging = new SynchronizedLogging(Stub(Clock), Stub(BuildOperationIdFactory))

    def "initialises on first usage"() {
        expect:
        logging.listenerManager != null
        logging.listenerManager == logging.listenerManager

        }

        @Provides
        protected LoggingProvider createLoggingProvider(Clock clock, BuildOperationIdFactory buildOperationIdFactory) {
            return new SynchronizedLogging(clock, buildOperationIdFactory);
        }

        @Provides