package org.apidesign.deadlock.logs;

import java.util.logging.Handler;

import java.util.logging.Level;

import java.util.logging.LogRecord;

import java.util.logging.Logger;

import org.junit.After;

import org.junit.AfterClass;

import org.junit.Before;

import org.junit.BeforeClass;

import org.junit.Test;

import org.netbeans.junit.NbTestCase;

import static org.junit.Assert.*;

// BEGIN: test.parallel.test.sorted

public class ParallelSortedTest extends NbTestCase {

    public ParallelSortedTest(String testName) {

        super(testName);

    }

    @Override

    protected Level logLevel() {

        return Level.WARNING;

    }

    public void testMain() throws Exception {

        Logger.global.addHandler(new BlockingHandler());

        Parallel.main(null);

        fail("Ok, just print the logged output");

    }

    private static final class BlockingHandler extends Handler {

        boolean runSecond;

        public synchronized void publish(LogRecord record) {

            if (!record.getMessage().startsWith("cnt")) {

                return;

            }

            boolean snd = Thread.currentThread().getName().equals("2nd");

            if (runSecond == snd) {

                notify();

                runSecond = !runSecond;

            }

            try {

                wait(500);

            } catch (InterruptedException ex) {

            }

        }

        public void flush() {

        }

        public void close() {

        }

    }

}

// END: test.parallel.test.sorted