我們已經知道java.util.lock中ReentrantLock可以替代synchronized加鎖但是synchronized可以配合wait()和notify()實現條件不滿足的時候等待,條件滿足的時候放行如果使用ReentrantLock怎么實現編寫wait和notify的功能呢?

這個時候我們就可以使用condition對象,condition對象就可以實現wait和notify的功能我們創建condition對象是通過lock.newCondition()方法返回的

Condition.wait/signal/signalAll原理和wait/notify/notifyAll一致1. await()會釋放鎖,進入等待狀態2. signal()會喚醒某個等待線程3. signalAll()會喚醒所有等待線程4. 喚醒線程從await()返回后需要重新獲的鎖對象 package com.leon.day05;import java.util.LinkedList; import java.util.Queue; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;public class TaskQueue {// 首先定義一個LinkedList來作為Queuefinal Queue<String> queue = new LinkedList<>();final Lock lock = new ReentrantLock();final Condition condition = lock.newCondition();public String getTask() throws InterruptedException {lock.lock();try { // 我們在getTask()方法中判斷是不是emptywhile(this.queue.isEmpty()) {// 如果是的話就進入等待狀態condition.await();}return queue.remove();}finally {lock.unlock();}}// 在addTask方法中首先獲得鎖,然后往隊列中添加一個任務,緊接著我們對condition對象調用public synchronized void addTask(String name) {lock.lock();try { // 我們在addTask()中向隊列加入一個任務this.queue.add(name);// signalAll喚醒正在等待的線程condition.signalAll();}finally {lock.unlock();}}public static void main(String[] args) throws InterruptedException {// 最后我們通過一個main方法創建一個TaskQueueTaskQueue taskQueue = new TaskQueue();// 創建一個WorkerThread,我們往TaskQueue中添加三個任務WorkerThread worker = new WorkerThread(taskQueue);worker.start();taskQueue.addTask("Bob");Thread.sleep(1000);taskQueue.addTask("Alice");Thread.sleep(1000);taskQueue.addTask("Tim");Thread.sleep(1000);worker.interrupt();worker.join();System.out.println("END");}}class WorkerThread extends Thread{TaskQueue taskQueue;public WorkerThread(TaskQueue taskQueue) {this.taskQueue = taskQueue;}@Overridepublic void run() {while(!isInterrupted()) {String name;try {// 不斷的從隊列中獲取任務// getTask有可能讓當前對象進入等待狀態// 當getTask返回的時候我們一定能夠拿到一個任務name = taskQueue.getTask();} catch (InterruptedException e) {break;}String result = "Hello, " + name + "!";System.out.println(result);} }}這個代碼的結果和我們使用synchronized和wait和notify是一樣的但是我們使用ReentrantLock和Condition可以更安全的實現線程的同步,等待和喚醒 Condition 可以用來替代 wait/notifyCondition對象必須從ReentrantLock對象中獲取ReentrantLock + Condition可以替代synchronized + wait/notify

?

總結

以上是生活随笔為你收集整理的Condition - Java多线程编程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。