package com.test;import java.util.concurrent.CountDownLatch;public class CountDownLatchDemo{public static void main(String args[]) throws Exception{CountDownLatch latch = new CountDownLatch(3);Worker worker1 = new Worker("Jack 程序员1",latch);Worker worker2 = new Worker("Rose 程序员2",latch);Worker worker3 = new Worker("Json 程序员3",latch);worker1.start();worker2.start();worker3.start();latch.await();System.out.println("Main thread end!");}static class Worker extends Thread {private String workerName;private CountDownLatch latch;public Worker(String workerName,CountDownLatch latch) {this.workerName = workerName;this.latch = latch;}@Overridepublic void run() {try {System.out.println("Worker:"+workerName +" is begin.");Thread.sleep(1000L);System.out.println("Worker:"+workerName +" is end.");} catch (InterruptedException e) {// TODO Auto-generated catch block
                e.printStackTrace();}//模仿干活；
            latch.countDown();}}
}

Worker:Rose 程序员2 is begin.
Worker:Json 程序员3 is begin.
Worker:Jack 程序员1 is begin.
Worker:Jack 程序员1 is end.
Worker:Json 程序员3 is end.
Worker:Rose 程序员2 is end.
Main thread end!

package com.test;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierDemo{public static void main(String args[]) throws Exception{CyclicBarrier barrier = new CyclicBarrier(3,new TotalTask());BillTask worker1 = new BillTask("111",barrier);BillTask worker2 = new BillTask("222",barrier);BillTask worker3 = new BillTask("333",barrier);worker1.start();worker2.start();worker3.start();System.out.println("Main thread end!");}static class TotalTask extends Thread {
public void run() {System.out.println("所有子任务都执行完了，就开始执行主任务了。");}}static class BillTask extends Thread {private String billName;private CyclicBarrier barrier;public BillTask(String workerName,CyclicBarrier barrier) {this.billName = workerName;this.barrier = barrier;}@Overridepublic void run() {try {System.out.println("市区:"+billName +"运算开始：");Thread.sleep(1000L);//模仿第一次运算；System.out.println("市区:"+billName +"运算完成，等待中...");barrier.await();//假设一次运算不完，第二次要依赖第一次的运算结果。都到达这个节点之后后面才会继续执行；System.out.println("全部都结束，市区"+billName +"才开始后面的工作。");} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}}}

市区:111运算开始：
市区:333运算开始：
Main thread end!
市区:222运算开始：
市区:333运算完成，等待中...
市区:222运算完成，等待中...
市区:111运算完成，等待中...
所有子任务都执行完了，就开始执行主任务了。//这句话是最后到达wait()方法的那个线程执行的
全部都结束，市区111才开始后面的工作。
全部都结束，市区222才开始后面的工作。
全部都结束，市区333才开始后面的工作。

package com.test;
import java.util.concurrent.Semaphore;
public class SemaphoreDemo{public static void main(String args[]) throws Exception{final Semaphore semaphore = new Semaphore(3);//一次只运行3个人进行访问for(int i=0;i<10;i++) {final int no = i;Runnable thread = new Runnable() {public void run (){try {System.out.println("用户"+no+"连接上了:");Thread.sleep(300L);semaphore.acquire();//获取接下去执行的许可System.out.println("用户"+no+"开始访问后台程序...");Thread.sleep(1000L);//模仿用户访问服务过程semaphore.release();//释放允许下一个线程访问进入后台System.out.println("用户"+no+"访问结束。");} catch (InterruptedException e) {e.printStackTrace();}}};new Thread(thread).start();}System.out.println("Main thread end!");}
}

用户1连接上了:
用户3连接上了:
用户4连接上了:
用户2连接上了:
用户0连接上了:
用户5连接上了:
用户7连接上了:
Main thread end!
用户6连接上了:
用户8连接上了:
用户9连接上了:
用户3开始访问后台程序...
用户4开始访问后台程序...
用户2开始访问后台程序...
用户4访问结束。
用户3访问结束。
用户7开始访问后台程序...
用户0开始访问后台程序...
用户8开始访问后台程序...
用户2访问结束。
用户5开始访问后台程序...
用户0访问结束。
用户7访问结束。
用户1开始访问后台程序...
用户8访问结束。
用户6开始访问后台程序...
用户1访问结束。
用户9开始访问后台程序...
用户5访问结束。
用户6访问结束。
用户9访问结束。