import org.junit.Test;

import java.util.Random;

/**
 * Тест потоков
 */
public class ThreadTest {
    private Runnable task;

    private boolean randomWait() {
        Random random = new Random();
        int waitTime = random.nextInt(1000);
        boolean interrupted = false;

        try {
            Thread.sleep(waitTime);
        } catch (InterruptedException e) {
            interrupted = true;
        }

        return !interrupted;
    }

    @Test
    public void happensBeforeTest() {
        Runnable createTask = new Runnable() {
            @Override
            public void run() {
                if (randomWait()) {
                    task = new TestRun("Все ОК!");
                }
            }
        };

        Runnable executeTask = new Runnable() {
            @Override
            public void run() {
                if (randomWait()) {
                    task.run();
                }
            }
        };

        Thread createTaskThread = new Thread(createTask);
        Thread executeTaskThread = new Thread(executeTask);

        createTaskThread.start();
        executeTaskThread.start();

        try {
            createTaskThread.join();
            executeTaskThread.join();
        } catch (InterruptedException ignored) {
        }
    }

    private static class TestRun implements Runnable {
        private String text;

        public TestRun(String text) {
            this.text = text;
        }

        public void run() {
            if (text == null) {
                System.out.println("Без аргумента");
            } else {
                try {
                    while (!Thread.currentThread().isInterrupted()) {
                        System.out.println("С аргументом: " + text);
                        Thread.sleep(1000);
                    }
                } catch (InterruptedException ignored) {
                }
            }
        }
    }
}