* limitations under the License.
 */

package org.gradle.test.fixtures.concurrent

/**
 * A point in time with an associated name.
 */
class NamedInstant extends Instant {
    private final String name
    private final int sequenceNumber

    NamedInstant(String name, long time, int sequenceNumber) {
        super(time)
        this.name = name
        this.sequenceNumber = sequenceNumber
    }

    @Override

/**
 * A dynamic collection of {@link NamedInstant} objects. When a property of this object is accessed from a test thread, a new instant is defined. When
 * accessed from the main thread, queries an existing instant, asserting that it exists.
 */
class Instants implements InstantFactory, OperationListener {
    private final Object lock = new Object()
    private final Map<String, NamedInstant> timePoints = [:]
    private Thread mainThread

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.test.fixtures.concurrent

interface InstantFactory {
    NamedInstant now(String name)

 */
@Timeout(60)
class ConcurrentSpec extends Specification {
    final TestLogger logger = new TestLogger()

    /**
     * An object that allows instants to be defined and queried.
     *
     * @see NamedInstant
     */
    final Instants instant = new Instants(logger)

    /**
     * An object that allows operations to be defined and queried.
     *
     * @see NamedOperation
     */