import java.io.BufferedWriter;import java.io.File;import java.io.FileWriter;import java.io.IOException;import java.util.Scanner;import java.util.concurrent.BlockingQueue;import java.util.concurrent.CountDownLatch;import java.util.concurrent.LinkedBlockingQueue;public class AsyncExecute {// (一)，用CountDownLatch控制多線程的執(zhí)行順序// (二)，多個(gè)線程同時(shí)工作時(shí)// (三)，但有一個(gè)線程需要等其他線程結(jié)束后才能開始 public AsyncExecute(CountDownLatch cdl) { this.latch = cdl; queue = new LinkedBlockingQueue(); File file = new File(“F:xbl1.sql”); try{ bw = new BufferedWriter(new FileWriter(file)); } catch(Exception ex) { ex.printStackTrace(); } } // 控制資源釋放 private CountDownLatch latch; // 阻塞隊(duì)列 private BlockingQueue queue; private BufferedWriter bw; private boolean finshedHandle = false; // 線程能發(fā)現(xiàn)volatile變量最新值 private volatile boolean sendFinished = false; public void sendFinish() { sendFinished = true; } // 釋放資源 public void release() { System.out.println(“release..”); if (bw != null) { try { bw.close(); } catch (IOException e) { } } if(queue != null) { queue.clear(); queue = null; } } // 往隊(duì)列發(fā)送消息 public void sendMsg(String text) { queue.add(text); } public void handle() { // 模擬性能瓶頸每3秒 new Thread( new Runnable() { public void run() { while(!finshedHandle) { try { Thread.sleep(3000); } catch(Exception ex) {} // 隊(duì)列中獲取 String s = queue !=null? queue.peek():null; if(s != null) { // remove彈出 queue.poll(); try { bw.write(s); bw.newLine(); } catch(Exception ex) {} } // 隊(duì)列為空 if(sendFinished) { /* CountDownLatch 是一個(gè)同步工具類, 用來(lái)協(xié)作多個(gè)線程間的同步,或起到線程間通信 (而不是互斥)。 (一)，他是通過(guò)計(jì)數(shù)器來(lái)實(shí)現(xiàn)的， (二)，計(jì)數(shù)器的初始值為線程的數(shù)量 * (三)，每當(dāng)一個(gè)線程完成任務(wù)后， (四)，計(jì)數(shù)器的值就會(huì)減1。 * (五)，當(dāng)計(jì)數(shù)器的值為0時(shí)， (六)，它表示所有線程已經(jīng)完成任務(wù) */ // 計(jì)數(shù)器1->0 latch.countDown(); finshedHandle = true; break; } } } } ).start(); } public static void main(String[] args)throws Exception { //(一)，CountDownLatch這個(gè)類 //(二)，可以使一個(gè)線程等待 //(三)，其他線程完成任務(wù)后再執(zhí)行 CountDownLatch latch = new CountDownLatch(1); AsyncExecute async = new AsyncExecute(latch); async.handle(); Scanner scanner = new Scanner(System.in); while(true) { String text = scanner.next(); if(text.equals(“exit”)) { async.sendFinish(); break; } async.sendMsg(text); } try { // 阻塞主線程,等待消息寫入到本地文件完成 latch.wait(); } catch(Exception ex) {} async.release(); scanner.close(); } }