使用CyclicBarrier同时启动多个线程

public class BaseThread
{
    protected CyclicBarrier barrier;
    public BaseThread(CyclicBarrier barrier)
    {
        this.barrier = barrier;
    }
}

public class Worker1 extends BaseThread implements Runnable
{
    public Worker1(CyclicBarrier barrier)
    {
        super(barrier);
    }

    @Override
    public void run()
    {
        try
        {
            barrier.await();
        } catch (InterruptedException e)
        {
            e.printStackTrace();
        } catch (BrokenBarrierException e)
        {
            e.printStackTrace();
        }

        System.out.println("worker1:" + System.nanoTime());
    }
}

public class Worker2 extends BaseThread implements Runnable
{
    public Worker2(CyclicBarrier barrier)
    {
        super(barrier);
    }

    @Override
    public void run()
    {
        try
        {
            barrier.await();
        } catch (InterruptedException e)
        {
            e.printStackTrace();
        } catch (BrokenBarrierException e)
        {
            e.printStackTrace();
        }
        System.out.println("worker2:" + System.nanoTime());
    }
}

public class Main
{
    public static void main(String... args) throws BrokenBarrierException, InterruptedException
    {
        CyclicBarrier barrier = new CyclicBarrier(3);
        new Thread(new Worker1(barrier)).start();
        new Thread(new Worker2(barrier)).start();
        barrier.await();
        System.out.println("main:" + System.nanoTime());
    }
}