1. 面試經常問到的三個併發工具類
嘿！ 如果你正準備找工作，那這篇文章就是為你量身準備的，不要想了，併發編程面試時一定會被問到的，下面給你介紹3個面試的時候經常會問到的併發編程工具類
下面介紹的三個類都出自java.util.concurrent包下。
最起碼你得知道它們是幹什麼用得，下面列出得代碼也建議你跑跑
1.1. (計數器)CountDownLatch
利用它可以實現類似計數器的功能
例如有個任務 task1，它要等待其他2個線程全部執行完畢之後才能執行，這是時候就可以考慮CountDownLatch來實現這種功能了。
CountDownLatch是通過一個計數器來實現的，計數器的初始值為線程的數量。
每當一個線程執行cdl.countDown()的方法，計數器的值就會減1。當初始值到達0時，它表示所有的線程已經完成了任務，然後在閉鎖上等待的線程就可以恢復執行任務。
<code>package cn.enjoy.mt;
import java.util.concurrent.CountDownLatch;
public class CountDownLatchTest {
public static void main(String[] args) throws InterruptedException {
CountDownLatch cdl = new CountDownLatch(2); //這裡的2代表,必須執行兩次countDown()
new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "，begin...");
cdl.countDown();
System.out.println(Thread.currentThread().getName() + ",end...");
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "，begin...");
cdl.countDown();//計數器值每次減去1
System.out.println(Thread.currentThread().getName() + ",end...");
}
}).start();
cdl.await();// 減去為0,恢復任務繼續執行
System.out.println("兩個Thread執行完畢....");
System.out.println("主線程繼續執行.....");
for (int i = 0; i <10; i++) {
System.out.println(Thread.currentThread().getName()+"，i:"+i);
}
}
}
/<code>
從結果可以看出，主線程只有等兩個子線程執行完成後才繼續執行
1.2. (屏障)CyclicBarrier
CyclicBarrier初始化時同樣也規定一個數目，然後計算調用了CyclicBarrier.await()進入等待的線程數。
當線程數達到了這個數目時，所有進入等待狀態的線程被喚醒並繼續。
CyclicBarrier就象它名字的意思一樣，可看成是個障礙， 所有的線程必須到齊後才能一起通過這個障礙。
CyclicBarrier初始時還可帶一個Runnable的參數， 此Runnable任務在CyclicBarrier的數目達到後，所有其它線程被喚醒前被執行。
<code>package cn.enjoy.mt;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
class Writer extends Thread {
private CyclicBarrier cbr;
public Writer(CyclicBarrier cbr) {
this.cbr = cbr;
}
@Override
public void run() {
try {
System.out.println("線程" + Thread.currentThread().getName() + ",正在寫入數據");
Thread.sleep(3000);
System.out.println("線程" + Thread.currentThread().getName() + ",寫入數據成功.....");
cbr.await();
System.out.println("所有線程執行完畢..........");
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class CyclicBarrierTest {
public static void main(String[] args) {
CyclicBarrier cyclicBarrier = new CyclicBarrier(5);
for (int i = 0; i < 5; i++) {
Writer writer = new Writer(cyclicBarrier);
writer.start();
}
}
}
/<code>
1.3. (計數信號量)Semaphore
Semaphore是一種基於計數的信號量。
它可以設定一個閾值，基於此，多個線程競爭獲取許可信號，做自己的申請後歸還，超過閾值後，線程申請許可信號將會被阻塞。
Semaphore可以用來構建一些對象池，資源池之類的，比如數據庫連接池，我們也可以創建計數為1的Semaphore，將其作為一種類似互斥鎖的機制，這也叫二元信號量，表示兩種互斥狀態。它的用法如下：
availablePermits函數用來獲取當前可用的資源數量
wc.acquire(); //申請資源
wc.release();// 釋放資源
需求: 一個按摩店只有3個技師，但是有10個老司機來按摩，那怎麼辦？
假設10的人的編號分別為1-10，並且1號先到技師，10號最後到技師。那麼1-3號來的時候必然有可用的技師，順利按摩，4號來的時候需要看看前面3人是否有人按摩完成出來了，如果有人出來，進去按摩，否則等待。
同樣的道理，4-10號也需要等待正在上按摩的人出來後才能進去按摩，代碼:
<code>package cn.enjoy.mt;
import java.util.Random;
import java.util.concurrent.Semaphore;
class UserThrad extends Thread {
private String name;
private Semaphore jsShop;
public UserThrad(String name, Semaphore jsShop) {
this.name = name;
this.jsShop = jsShop;
}
@Override
public void run() {
// 剩下的技師
int availablePermits = jsShop.availablePermits();
if (availablePermits > 0) {
System.out.println(name + ",找到小姐姐按摩了....");
} else {
System.out.println(name + ",真可惜，還得等...");
}
try {
// 申請技師
jsShop.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(name + "開始按摩咯" + ",剩下的技師數:" + jsShop.availablePermits());
try {
Thread.sleep(new Random().nextInt(1000));
} catch (Exception e) {
}
System.out.println(name + "按摩完咯!，舒服");
// 釋放技師
jsShop.release();
}
}
public class SemaphoreTest {
public static void main(String[] args) {
Semaphore semaphore = new Semaphore(4);
for (int i = 1; i <= 10; i++) {
UserThrad userThrad = new UserThrad("第" + i + "個人", semaphore);
userThrad.start();
}
}
}/<code>
閱讀更多 享學課堂online 的文章
