java并发 CyclicBarrier (四)
import java.util.concurrent.CyclicBarrier;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class CyclicBarrierTest {public static void main(String[] args) {//声明CyclicBarrierint threadNum=5;final CyclicBarrier cycbarrier=new CyclicBarrier(threadNum,new Runnable(){@Overridepublic void run() {//该线程是所有的任务线程都运行完毕之后最后才运行System.out.println("------last end-------------");}});ExecutorService executorService=Executors.newCachedThreadPool();//运行的线程集合for(int i=0;i<threadNum;i++){executorService.execute(new CyclicBarrierTask(cycbarrier));}executorService.shutdown();}}
?
?
??
import java.util.concurrent.BrokenBarrierException;import java.util.concurrent.CyclicBarrier;public class CyclicBarrierTask implements Runnable {private CyclicBarrier cyclicBarrier;public CyclicBarrierTask(CyclicBarrier cyclicBarrier){this.cyclicBarrier=cyclicBarrier;}@Overridepublic void run() {System.out.println("run task ,name:"+Thread.currentThread().getName());try {Thread.sleep(1000);cyclicBarrier.await();System.out.println("---------------------------------------");} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}}?