/*** Created by DELL on 2017/1/4.*/
import java.util.concurrent.CountDownLatch;public class Thread2 {/*** 计数器，用来控制线程* 传入参数2，表示计数器计数为2*/private final static CountDownLatch mCountDownLatch = new CountDownLatch(2);/*** 示例工作线程类*/private static class WorkingThread extends Thread {private final String mThreadName;private final int mSleepTime;public WorkingThread(String name, int sleepTime) {mThreadName = name;mSleepTime = sleepTime;}@Overridepublic void run() {System.out.println("[" + mThreadName + "] started!");try {Thread.sleep(mSleepTime);} catch (InterruptedException e) {e.printStackTrace();}mCountDownLatch.countDown();//减一System.out.println("[" + mThreadName + "] end!");}}/*** 示例线程类*/private static class SampleThread extends Thread {@Overridepublic void run() {System.out.println("[SampleThread] started!");try {// 会阻塞在这里等待 mCountDownLatch 里的count变为0；// 也就是等待另外的WorkingThread调用countDown()mCountDownLatch.await();} catch (InterruptedException e) {}System.out.println("[SampleThread] end!");}}public static void main(String[] args) throws Exception {// 最先run SampleThreadnew SampleThread().start();// 运行两个工作线程// 工作线程1运行5秒new WorkingThread("WorkingThread1", 5000).start();// 工作线程2运行2秒new WorkingThread("WorkingThread2", 2000).start();}
}

[SampleThread] started![WorkingThread2] started![WorkingThread1] started![WorkingThread2] end![WorkingThread1] end![SampleThread] end!

import java.util.concurrent.CyclicBarrier;/*** Created by DELL on 2017/1/4.*/
public class thread3 {public static final int INIT_NUM = 5;public static void main(String[] args) {CyclicBarrier cyc = new CyclicBarrier(INIT_NUM, new Runnable() {@Overridepublic void run() {System.out.println("init cyclicBarrier----");}});for (int i = 0; i < INIT_NUM; i++) {new sampleCyclic(cyc).start();}}private static class sampleCyclic extends Thread {CyclicBarrier barrier;public sampleCyclic(CyclicBarrier barrier) {this.barrier = barrier;}@Overridepublic void run() {System.out.println("start=====");try {barrier.await();} catch (Exception e) {e.printStackTrace();}System.out.println("id" + Thread.currentThread().getId() + "working----");}}}

start=====
start=====
start=====
start=====
start=====
init cyclicBarrier----
id16working----
id13working----
id15working----
id14working----
id12working----