[AppleScript] 纯文本查看 复制代码
public class CyclicBarrierTest {
boolean finalFlg = false;
/**
* CyclicBarrier 适用再多线程相互等待，直到到达一个屏障点。并且CyclicBarrier是可重用的。
*/
CyclicBarrier cyclicBarrier = new CyclicBarrier(10);
private void runThread() {
ExecutorService executorService = Executors.newFixedThreadPool(10);
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
executorService.submit(createThread(i));
}
}
private Thread createThread(int i) {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
try {
cyclicBarrier.await();
System.out.println("Thread:" + Thread.currentThread().getName() + "准备完毕,time:" + System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
});
thread.setName("name" + i);
return thread;
}
public static void main(String[] args) {
CyclicBarrierTest test = new CyclicBarrierTest();
test.runThread();
}
}
[AppleScript] 纯文本查看 复制代码
Thread:pool-1-thread-10准备完毕,time:1521037864652
Thread:pool-1-thread-1准备完毕,time:1521037864652
Thread:pool-1-thread-3准备完毕,time:1521037864652
Thread:pool-1-thread-2准备完毕,time:1521037864652
Thread:pool-1-thread-7准备完毕,time:1521037864652
Thread:pool-1-thread-6准备完毕,time:1521037864652
Thread:pool-1-thread-5准备完毕,time:1521037864652
Thread:pool-1-thread-4准备完毕,time:1521037864652
Thread:pool-1-thread-9准备完毕,time:1521037864652
Thread:pool-1-thread-8准备完毕,time:1521037864652