我们程序中使用多线程,一般就是一个一个开启,让他们分别去执行各自的任务.但是有些时候我们是希望这些线程同时开始运行的.比如模拟多个人参加跑步比赛.要让这些人同时开跑.要如何实现呢?
这里我们介绍一个不太常用的类.CyclicBarrier.同步屏障. 用他就可以实现多个线程的同时开启.下面介绍一下这个类如何使用.
CyclicBarrier 的字面意思是可循环使用（Cyclic）的屏障（Barrier）。它要做的事情是，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活。CyclicBarrier默认的构造方法是CyclicBarrier(int parties)，其参数表示屏障拦截的线程数量，每个线程调用await方法告诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。
[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
这个同时运行的场景,就完美的实现了.
| 
收藏
淘帖
踩
