type PriorityQueue []*Item

func (pq PriorityQueue) Len() int { return len(pq) }

func (pq PriorityQueue) Less(i, j int) bool {
	// We want Pop to give us the highest, not lowest, priority so we use greater than here.
	return pq[i].priority > pq[j].priority
}

func (pq PriorityQueue) Swap(i, j int) {
	pq[i], pq[j] = pq[j], pq[i]
	pq[i].index = i
	pq[j].index = j
}

     */
    <K, V> IndexedCache<K, V> createIndexedCache(String name, Class<K> keyType, Serializer<V> valueSerializer);

    <K, V> boolean indexedCacheExists(IndexedCacheParameters<K, V> parameters);

    /**
     * Closes this cache, blocking until all operations are complete.
     */
    @Override
    void close();

        then:
        ref1.reference.cache.is(ref2.reference.cache)

        and:
        1 * opened.accept(_)
        0 * opened._

        cleanup:
        factory.close()
    }

    void "closes cache instance when factory is closed"() {
        def implementation

        when:
        factory.open(tmpDir.testDirectory, null, [prop: 'value'], mode(Exclusive), null, null)

        then:

 * of module sources:
 *
 * <ul>
 *     <li>sources which can be reconstructed from the caches, for example, the repository source</li>
 *     <li>sources which can't be reconstructed because the cache format loses information, for example a descriptor converted to binary</li>
 * </ul>
 *
 * The 2d kind, sources which must be stored into the metadata cache, have to implement the {@link PersistentModuleSource}
 * interface instead.
 */

    static final Set<String> SUPPORTS_PARAMETERS
    static final Set<String> SUPPORTS_DISABLING_AST_TRANSFORMATIONS
    static final Set<String> SINCE_3_0

    /**
     * The lowest working Groovy 3 version for the current JDK.
     */
    static final String MINIMAL_GROOVY_3

    /**
     * The current Groovy version if stable, otherwise the latest stable version before the current version.
     */

     * This may happen because the peer has signalled that it has finished sending messages, or closes the connection, or crashes. It may also happen when
     * this side of the connection is closed using {@link ObjectConnection#stop()}.
     * </p>
     *

        value = "Some message"
    }

    def "returns null when accessing value of a non existing header"() {
        expect:
        resource().getHeaderValue("X-No-Such-Header") == null
    }

    def "close closes the response"() {
        given:
        def mockedHttpResponse = mockedHttpResponse(response)

        when:
        resource().close()

        then:
        interaction {

     */
    fun loadOrCreateProjectMetadata(identityPath: Path, creator: () -> LocalComponentGraphResolveState): LocalComponentGraphResolveState

    /**
     * Flushes any remaining state to the cache and closes any resources
     */
    fun finalizeCacheEntry()

    // This is a temporary property to allow migration from a root build scoped cache to a build tree scoped cache
    val isLoaded: Boolean

			// If ServeHTTP panics, the server (the caller of ServeHTTP) assumes
			// that the effect of the panic was isolated to the active request.
			// It recovers the panic, logs a stack trace to the server error log,
			// and either closes the network connection or sends an HTTP/2
			// RST_STREAM, depending on the HTTP protocol. To abort a handler so
			// the client sees an interrupted response but the server doesn't log

            LOGGER.debug("Exception while consuming empty object content from metadata request", e);
        } finally {
            // This also closes objectContent, no need to close it explicitly.
            IoActions.closeQuietly(s3Object);
        }
    }

    @Override