新的起點(diǎn) 新的開始

public class Server {

????? public static void main(String[] args) throws InterruptedException{

??????????? System.out.println("Server is starting.");

?????????? ?// 初始化一個(gè)初始值為 3 的 CountDownLatch

??????????? CountDownLatch latch = new CountDownLatch(3);

??????????? // 起 3 個(gè)線程分別去啟動(dòng) 3 個(gè)組件

??????????? ExecutorService service = Executors.newCachedThreadPool();

??????????? service.submit(new ComponentThread(latch, 1));

????????? ??service.submit(new ComponentThread(latch, 2));

??????????? service.submit(new ComponentThread(latch, 3));

??????????? service.shutdown();

??????????? // 進(jìn)入等待狀態(tài)

??????????? latch.await();

??????????? // 當(dāng)所需的三個(gè)組件都完成時(shí)， Server 就可繼續(xù)了

??????????? System.out.println("Server is up!");

????? }

}

?

public class ComponentThread implements Runnable{

????? CountDownLatch latch;

????? int ID;

????? /** Creates a new instance of ComponentThread */

????? public ComponentThread(CountDownLatch latch, int ID) {

??????????? this.latch = latch;

??????????? this.ID = ID;

????? }

????? public void run() {

??????????? System.out.println("Component "+ID + " initialized!");

??????????? // 將計(jì)數(shù)減一

??????????? latch.countDown();

????? }????

}

Server is starting.

Component 1 initialized!

Component 3 initialized!

Component 2 initialized!

Server is up!

public class MainThread {

public static void main(String[] args)

????? throws InterruptedException, BrokenBarrierException, TimeoutException{

??????????? final int[] array = new int[2];

??????????? CyclicBarrier barrier = new CyclicBarrier(2,

????????????????? new Runnable() {// 在所有線程都到達(dá) Barrier 時(shí)執(zhí)行

????????????????? public void run() {

??????????????????????? System.out.println("Total is:"+(array[0]+array[1]));

????????????????? }

??????????? });???????????

??????????? // 啟動(dòng)線程

??????????? new Thread(new ComponentThread(barrier, array, 0)).start();

??????????? new Thread(new ComponentThread(barrier, array, 1)).start();???

????? }?????

}

?

public class ComponentThread implements Runnable{

????? CyclicBarrier barrier;

????? int ID;

????? int[] array;

????? public ComponentThread(CyclicBarrier barrier, int[] array, int ID) {

??????????? this.barrier = barrier;

??????????? this.ID = ID;

??????????? this.array = array;

????? }

????? public void run() {

??????????? try {

????????????????? array[ID] = new Random().nextInt();

????????????????? System.out.println(ID+ " generates:"+array[ID]);

????????????????? // 該線程完成了任務(wù)等在 Barrier 處

????????????????? barrier.await();

??????????? } catch (BrokenBarrierException ex) {

????????????????? ex.printStackTrace();

??????????? } catch (InterruptedException ex) {

????????????????? ex.printStackTrace();

??????????? }

????? }

}

class FillAndEmpty {

????? // 初始化一個(gè) Exchanger ，并規(guī)定可交換的信息類型是 DataCup

????? Exchanger exchanger = new Exchanger();

???? ?Cup initialEmptyCup = ...; // 初始化一個(gè)空的杯子

????? Cup initialFullCup = ...; // 初始化一個(gè)裝滿水的杯子

????? // 服務(wù)生線程

????? class Waiter implements Runnable {

??????????? public void run() {

????????????????? Cup currentCup = initialEmptyCup;

????????????????? try {

?????? ?????????????????// 往空的杯子里加水

??????????????????????? currentCup.addWater();

??????????????????????? // 杯子滿后和顧客的空杯子交換

??????????????????????? currentCup = exchanger.exchange(currentCup);

????????????????? } catch (InterruptedException ex) { ... handle ... }

? ?????????? }

????? }

????? // 顧客線程

????? class Customer implements Runnable {

??????????? public void run() {

????????????????? DataCup currentCup = initialFullCup;

????????????????? try {

??????????????????????? // 把杯子里的水喝掉

??????????????????????? currentCup.drinkFromCup();

??????????????????????? // 將空杯子和服務(wù)生的滿杯子交換

??????????????????????? currentCup = exchanger.exchange(currentCup);

????????????????? } catch (InterruptedException ex) { ... handle ...}

??????????? }

????? }

?????

????? void start() {

??????? ????new Thread(new Waiter()).start();

??????????? new Thread(new Customer()).start();

????? }

}

public class BlockingQueueTest {

????? static BlockingQueue basket;

????? public BlockingQueueTest() {

??????????? // 定義了一個(gè)大小為 2 的 BlockingQueue ，也可根據(jù)需要用其他的具體類

??????????? basket = new ArrayBlockingQueue(2);

????? }

????? class Producor implements Runnable {

??????????? public void run() {

????????????????? while(true){

??????????????????????? try {

????????????????????????????? // 放入一個(gè)對象，若 basket 滿了，等到 basket 有位置

?????????????????????? ???????basket.put("An apple");

??????????????????????? } catch (InterruptedException ex) {

????????????????????????????? ex.printStackTrace();

??????????????????????? }

????????????????? }

??????????? }

????? }

????? class Consumer implements Runnable {

? ??????????public void run() {

????????????????? while(true){

??????????????????????? try {

????????????????????????????? // 取出一個(gè)對象，若 basket 為空，等到 basket 有東西為止

????????????????????????????? String result = basket.take();

??????????????????????? } catch (InterruptedException ex) {

????????????????????????????? ex.printStackTrace();

??????????????????????? }

????????????????? }

????? ??????}???????????

????? }

????? public void execute(){

??????????? for(int i=0; i<10; i++){

????????????????? new Thread(new Producor()).start();

????????????????? new Thread(new Consumer()).start();

??????????? }???????????

????? }

????? public static void main(String[] args){

??????????? BlockingQueueTest test = new BlockingQueueTest();

??????????? test.execute();

????? }?????

}