* limitations under the License.
 */

package org.gradle.test.fixtures.concurrent

interface OperationListener {
    void operationStarted()

    void operationFinished()

        }
        listener.operationStarted()
        try {
            action.run()
        } finally {
            operation.completed(instantFactory.now(operation.name))
            listener.operationFinished()
        }
    }

    }

    @Override
    String toString() {
        return "instants"
    }

    void operationStarted() {
        synchronized (lock) {
            operations++
        }
    }

    void operationFinished() {
        synchronized (lock) {
            operations--
            lock.notifyAll()
        }
    }

    void mainThread(Thread thread) {
        synchronized (lock) {
            mainThread = thread;

        server.expectConcurrent("operationsStarted", "parallelTaskStarted")
        server.expectConcurrent("operationsFinished", "parallelTaskFinished")

        buildFile << """
            def beforeOperations = { ${server.callFromBuild("operationsStarted")} }
            def afterOperations = { ${server.callFromBuild("operationsFinished")} }

            task parallelTask {
                dependsOn { tasks.${taskName}.taskDependencies }