when:
        def lock = registry.getResourceLock("test")

        then:
        lock instanceof TestTrackedResourceLock

        when:
        lock.tryLock()

        then:
        registry.getResourceLocksByCurrentThread() == [lock]
    }

    def "does not get locks associated with other threads"() {
        when:
        def lock = registry.getResourceLock("test")

        sharedResourceLeaseRegistry.registerSharedResource('resource-b', 1)

        and:
        def lockA = sharedResourceLeaseRegistry.getResourceLock('resource-a')
        def lockB = sharedResourceLeaseRegistry.getResourceLock('resource-b')

        when:
        coordinationService.withStateLock(lock(lockA))
        coordinationService.withStateLock(lock(lockB))

        then:

    /**
     * Submit a new conditional execution to the queue.  The execution will occur asynchronously when the provided
     * resource lock (see {@link ConditionalExecution#getResourceLock()}) can be acquired.  On completion,
     * {@link ConditionalExecution#complete()} will be called.
     */
    void submit(ConditionalExecution<T> execution);

    /**

    }

    public void registerSharedResource(String name, int leases) {
        sharedResources.put(name, new LeaseHolder(leases));
    }

    public ResourceLock getResourceLock(final String sharedResource) {
        String displayName = "lease for " + sharedResource;
        return new DefaultLease(displayName, coordinationService, this, sharedResources.get(sharedResource));
    }

 */

package org.gradle.internal.resources;

public interface SharedResource {
    /**
     * @return The maximum usage, or -1 when there is no limit.
     */
    int getMaxUsages();

    ResourceLock getResourceLock();