public class TestUtil {
private static final int USE_NUM = 5;
private CyclicBarrier barrier = new CyclicBarrier(USE_NUM, new Runnable() {
@Override
public void run() {
System.out.println("整齐划一");
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
void start() {
for (int i = 0; i < USE_NUM; i++) {
new Thread(new Worker()).start();
}
}
public static void main(String[] args) {
new TestUtil().start();
}
public class Worker implements Runnable {
@Override
public void run() {
try {
for (int i = 0; i < 5; i++) {
System.out.println(Thread.currentThread() + "执行" + i);
//等待所有线程执行完毕
barrier.await();
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
}
}