*
 * <p>You can use {@link #syncAt(int)} and {@link #expectBlocksUntil(int, groovy.lang.Closure)} to synchronise between
 * test threads.</p>
 */
public class MultithreadedTestRule extends ExternalResource {
    private static final Logger LOGGER = LoggerFactory.getLogger(MultithreadedTestRule.class);
    private static final int MAX_WAIT_TIME = 5000;
    private ExecutorImpl executor;
    private final Lock lock = new ReentrantLock();

class LongIdGeneratorTest {
    private final LongIdGenerator generator = new LongIdGenerator()

    @Rule
    public MultithreadedTestRule parallel = new MultithreadedTestRule();

    @Test
    void generatesMonotonicallyIncreasingLongIdsStartingAtOne() {
        assertThat(generator.generateId(), equalTo(1L))
        assertThat(generator.generateId(), equalTo(2L))

package org.gradle.internal.dispatch

import org.gradle.util.internal.MultithreadedTestRule
import org.junit.Rule
import spock.lang.Specification

import static org.hamcrest.CoreMatchers.sameInstance

public class AsyncDispatchTest extends Specification {
    private final Dispatch<String> target1 = Mock()

    @Rule
    public MultithreadedTestRule parallel = new MultithreadedTestRule()

- `Resources`
- `RedirectStdOutAndErr`
- `Swapper`
- `StdInSwapper`
- `IncubationLogger`
- `RedirectStdIn`
- `MultithreadedTestRule`
- `DisconnectableInputStream`
- `BulkReadInputStream`
- `MockExecutor`
- `FailsWithMessage`
- `FailsWithMessageExtension`
- `TreeVisitor`
- `AntUtil`
- `JarUtil`