Concurrent

用ReentrantLock+Condition實(shí)現(xiàn)Blocking Queue。
Blocking Queue：當(dāng)一個(gè)線程調(diào)用getTask()時(shí)，該方法內(nèi)部可能讓給線程進(jìn)入等待狀態(tài)，直到條件滿足。線程喚醒以后，getTask()才會(huì)返回，而java.util.concurrent提供了線程安全的Blocking集合，如ArrayBlockingQueue。

class TaskQueue{final Queue<String> queue = new LinkedList<>();final Lock lock = new ReentrantLock();final Condition noEmpty = lock.newCondition();public String getTask(){...}public void addTask(String name){...} } import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue;class WorkerThread extends Thread{BlockingQueue<String> taskQueue;public WorkerThread(BlockingQueue<String> taskQueue){this.taskQueue = taskQueue;}public void run(){while(!isInterrupted()){String name;try{name = taskQueue.take();}catch (InterruptedException e){break;}String result = "Hello,"+name+"!";System.out.println(result);}} } public class Main{public static void main(String[] args) throws Exception{BlockingQueue<String> taskQueue = new ArrayBlockingQueue<>(1000);WorkerThread worker = new WorkerThread(taskQueue);worker.start();taskQueue.put("Bob");Thread.sleep(1000);taskQueue.put("Alice");Thread.sleep(1000);taskQueue.put("Tim");Thread.sleep(1000);worker.interrupt();worker.join();System.out.println("END");} }

java.util.Collections工具類還提供了舊的線程安全集合轉(zhuǎn)換器：
如把一個(gè)HashMap轉(zhuǎn)化為線程安全的HashMap：

Map unsafeMap = new HashMap(); Map threadSafeMap = Collections.synchronizedMap(unsafeMap);

實(shí)際使用了一個(gè)包裝類，包裝了非線程安全的Map，然后對(duì)所有的方法都用synchronized加鎖，這樣獲得線程安全的集合，性能比Concurrent低很多，不推薦使用。

總結(jié)：

使用java.util.concurrent提供的Blocking集合可以簡(jiǎn)化多線程編程

• 多線程同時(shí)訪問Blocking集合是安全的
• 盡量使用JDK提供的concurrent集合，避免自己編寫同步代碼

轉(zhuǎn)載于:https://www.cnblogs.com/csj2018/p/11016289.html

總結(jié)

以上是生活随笔為你收集整理的廖雪峰Java11多线程编程-3高级concurrent包-4Concurrent集合的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。